Package rx.internal.operators
Class BlockingOperatorLatest
java.lang.Object
rx.internal.operators.BlockingOperatorLatest
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.-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
Observer of source, iterator for output. -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic <T> Iterable
<T> latest
(Observable<? extends T> source) Returns anIterable
that blocks until or unless theObservable
emits an item that has not been returned by theIterable
, then returns that item
-
Constructor Details
-
BlockingOperatorLatest
private BlockingOperatorLatest()Utility class.
-
-
Method Details
-
latest
Returns anIterable
that blocks until or unless theObservable
emits an item that has not been returned by theIterable
, then returns that item- Type Parameters:
T
- the value type- Parameters:
source
- the sourceObservable
- Returns:
- an
Iterable
that blocks until or unless theObservable
emits an item that has not been returned by theIterable
, then returns that item
-