Class BlockingFlowableNext.NextSubscriber<T>

java.lang.Object
io.reactivex.rxjava3.subscribers.DisposableSubscriber<Notification<T>>
io.reactivex.rxjava3.internal.operators.flowable.BlockingFlowableNext.NextSubscriber<T>
All Implemented Interfaces:
FlowableSubscriber<Notification<T>>, Disposable, org.reactivestreams.Subscriber<Notification<T>>
Enclosing class:
BlockingFlowableNext<T>

static final class BlockingFlowableNext.NextSubscriber<T> extends DisposableSubscriber<Notification<T>>