Package rx.internal.operators
Class BlockingOperatorLatest
- java.lang.Object
-
- rx.internal.operators.BlockingOperatorLatest
-
public final class BlockingOperatorLatest extends java.lang.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 theonError
oronCompleted
events.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
BlockingOperatorLatest.LatestObserverIterator<T>
Observer of source, iterator for output.
-
Constructor Summary
Constructors Modifier Constructor Description private
BlockingOperatorLatest()
Utility class.
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T> java.lang.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
-
-
-
Method Detail
-
latest
public static <T> java.lang.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- 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
-
-