Package rx.internal.operators
Class BlockingOperatorNext
- java.lang.Object
-
- rx.internal.operators.BlockingOperatorNext
-
public final class BlockingOperatorNext extends java.lang.Object
Returns an Iterable that blocks until the Observable emits another item, then returns that item.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
BlockingOperatorNext.NextIterator<T>
(package private) static class
BlockingOperatorNext.NextObserver<T>
-
Constructor Summary
Constructors Modifier Constructor Description private
BlockingOperatorNext()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T> java.lang.Iterable<T>
next(Observable<? extends T> items)
Returns anIterable
that blocks until theObservable
emits another item, then returns that item.
-
-
-
Method Detail
-
next
public static <T> java.lang.Iterable<T> next(Observable<? extends T> items)
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
-
-