Class BlockingOperatorLatest


  • public final class BlockingOperatorLatest
    extends java.lang.Object
    Wait for and iterate over the latest values of the source observable. If the source works faster than the iterator, values may be skipped, but not the onError or onCompleted events.
    • Constructor Summary

      Constructors 
      Modifier Constructor Description
      private BlockingOperatorLatest()
      Utility class.
    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static <T> java.lang.Iterable<T> latest​(Observable<? extends T> source)
      Returns an Iterable that blocks until or unless the Observable emits an item that has not been returned by the Iterable, then returns that item
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • BlockingOperatorLatest

        private BlockingOperatorLatest()
        Utility class.
    • Method Detail

      • latest

        public static <T> java.lang.Iterable<T> latest​(Observable<? extends T> source)
        Returns an Iterable that blocks until or unless the Observable emits an item that has not been returned by the Iterable, then returns that item
        Type Parameters:
        T - the value type
        Parameters:
        source - the source Observable
        Returns:
        an Iterable that blocks until or unless the Observable emits an item that has not been returned by the Iterable, then returns that item