Uses of Interface
rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback

Packages that use BackpressureDrainManager.BackpressureQueueCallback

Package	Description
rx.internal.operators	Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.
rx.internal.util

Uses of BackpressureDrainManager.BackpressureQueueCallback in rx.internal.operators

Classes in rx.internal.operators that implement BackpressureDrainManager.BackpressureQueueCallback

Modifier and Type	Class	Description
(package private) static class	OperatorOnBackpressureBuffer.BufferSubscriber<T>

Uses of BackpressureDrainManager.BackpressureQueueCallback in rx.internal.util

Fields in rx.internal.util declared as BackpressureDrainManager.BackpressureQueueCallback

Modifier and Type	Field	Description
(package private) BackpressureDrainManager.BackpressureQueueCallback	BackpressureDrainManager.actual	The callbacks to manage the drain.

Constructors in rx.internal.util with parameters of type BackpressureDrainManager.BackpressureQueueCallback

Constructor	Description
BackpressureDrainManager(BackpressureDrainManager.BackpressureQueueCallback actual)	Constructs a backpressure drain manager with 0 requestedCount, no terminal event and not emitting.