Class BlockingObservableLatest<T>

java.lang.Object
io.reactivex.rxjava3.internal.operators.observable.BlockingObservableLatest<T>
Type Parameters:
T - the value type
All Implemented Interfaces:
Iterable<T>

public final class BlockingObservableLatest<T> extends Object implements Iterable<T>
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 onComplete events.