Class BlockingOperatorLatest



  • public final class BlockingOperatorLatest
    extends 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.
    • Method Detail

      • latest

        public static <T> 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
        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