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.
-