Package rx.internal.operators
Class BlockingOperatorNext
java.lang.Object
rx.internal.operators.BlockingOperatorNext
Returns an Iterable that blocks until the Observable emits another item, then returns that item.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
(package private) static final class
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic <T> Iterable
<T> next
(Observable<? extends T> items) Returns anIterable
that blocks until theObservable
emits another item, then returns that item.
-
Constructor Details
-
BlockingOperatorNext
private BlockingOperatorNext()
-
-
Method Details
-
next
Returns anIterable
that blocks until theObservable
emits another item, then returns that item.- Type Parameters:
T
- the value type- Parameters:
items
- theObservable
to observe- Returns:
- an
Iterable
that behaves like a blocking version ofitems
-