Class ObservableCollectWithCollector.CollectorObserver<T,A,R>

All Implemented Interfaces:
Observer<T>, Disposable, QueueDisposable<R>, QueueFuseable<R>, SimpleQueue<R>, Serializable
Enclosing class:
ObservableCollectWithCollector<T,A,R>

static final class ObservableCollectWithCollector.CollectorObserver<T,A,R> extends DeferredScalarDisposable<R> implements Observer<T>