Class BlockingOperatorLatest.LatestObserverIterator<T>

java.lang.Object
rx.Subscriber<Notification<? extends T>>
rx.internal.operators.BlockingOperatorLatest.LatestObserverIterator<T>
All Implemented Interfaces:
Iterator<T>, Observer<Notification<? extends T>>, Subscription
Enclosing class:
BlockingOperatorLatest

static final class BlockingOperatorLatest.LatestObserverIterator<T> extends Subscriber<Notification<? extends T>> implements Iterator<T>
Observer of source, iterator for output.