Package rx.internal.operators

Class BlockingOperatorLatest

java.lang.Object

rx.internal.operators.BlockingOperatorLatest

public final class BlockingOperatorLatest
extends 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 the onError or onCompleted events.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	BlockingOperatorLatest.LatestObserverIterator<T>	Observer of source, iterator for output.

Constructor Summary

Constructors

Modifier	Constructor	Description
private	BlockingOperatorLatest()	Utility class.

Method Summary

Modifier and Type	Method	Description
static <T> Iterable<T>	latest(Observable<? extends T> source)	Returns an Iterable that blocks until or unless the Observable emits an item that has not been returned by the Iterable, then returns that item

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BlockingOperatorLatest

private BlockingOperatorLatest()

Utility class.

Method Details

latest

public static <T> Iterable<T> latest(Observable<? extends T> source)

Returns an Iterable that blocks until or unless the Observable emits an item that has not been returned by the Iterable, then returns that item

Type Parameters:

T - the value type

Parameters:

source - the source Observable

Returns:

an Iterable that blocks until or unless the Observable emits an item that has not been returned by the Iterable, then returns that item