Class ParallelCollector.ParallelCollectorSubscriber<T,A,R>

All Implemented Interfaces:
QueueFuseable<R>, QueueSubscription<R>, SimpleQueue<R>, Serializable, org.reactivestreams.Subscription
Enclosing class:
ParallelCollector<T,A,R>

static final class ParallelCollector.ParallelCollectorSubscriber<T,A,R> extends DeferredScalarSubscription<R>