Class BlockingOperatorNext.NextObserver<T>

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

static final class BlockingOperatorNext.NextObserver<T> extends Subscriber<Notification<? extends T>>