Package rx.internal.operators
Class BlockingOperatorLatest
- java.lang.Object
-
- rx.internal.operators.BlockingOperatorLatest
-
public final class BlockingOperatorLatest extends java.lang.ObjectWait 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 theonErrororonCompletedevents.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static classBlockingOperatorLatest.LatestObserverIterator<T>Observer of source, iterator for output.
-
Constructor Summary
Constructors Modifier Constructor Description privateBlockingOperatorLatest()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 anIterablethat blocks until or unless theObservableemits 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 anIterablethat blocks until or unless theObservableemits 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
Iterablethat blocks until or unless theObservableemits an item that has not been returned by theIterable, then returns that item
-
-