Class BlockingOperatorLatest

java.lang.Object
rx.internal.operators.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.
  • Constructor Details

    • BlockingOperatorLatest

      private BlockingOperatorLatest()
      Utility class.
  • Method Details

    • 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
      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