Uses of Interface
rx.internal.util.BackpressureDrainManager.BackpressureQueueCallback
Packages that use BackpressureDrainManager.BackpressureQueueCallback
Package
Description
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
-
Uses of BackpressureDrainManager.BackpressureQueueCallback in rx.internal.operators
Classes in rx.internal.operators that implement BackpressureDrainManager.BackpressureQueueCallbackModifier and TypeClassDescription(package private) static final class
-
Uses of BackpressureDrainManager.BackpressureQueueCallback in rx.internal.util
Fields in rx.internal.util declared as BackpressureDrainManager.BackpressureQueueCallbackModifier and TypeFieldDescription(package private) final BackpressureDrainManager.BackpressureQueueCallback
BackpressureDrainManager.actual
The callbacks to manage the drain.Constructors in rx.internal.util with parameters of type BackpressureDrainManager.BackpressureQueueCallbackModifierConstructorDescriptionConstructs a backpressure drain manager with 0 requestedCount, no terminal event and not emitting.