Class BlockingOperatorNext

java.lang.Object
rx.internal.operators.BlockingOperatorNext

public final class BlockingOperatorNext extends Object
Returns an Iterable that blocks until the Observable emits another item, then returns that item.

  • Constructor Details

    • BlockingOperatorNext

      private BlockingOperatorNext()
  • Method Details

    • next

      public static <T> Iterable<T> next(Observable<? extends T> items)
      Returns an Iterable that blocks until the Observable emits another item, then returns that item.
      Type Parameters:
      T - the value type
      Parameters:
      items - the Observable to observe
      Returns:
      an Iterable that behaves like a blocking version of items