Package | Description |
---|---|
rx.internal.util |
Constructor and Description |
---|
BackpressureDrainManager(BackpressureDrainManager.BackpressureQueueCallback actual)
Constructs a backpressure drain manager with 0 requestedCount,
no terminal event and not emitting.
|
Copyright © 2018. All rights reserved.