Sink.queue
Materialize a SinkQueue
that can be pulled to trigger demand through the sink.
Signature
Description
Materialize a SinkQueue
that can be pulled to trigger demand through the sink. The queue contains a buffer in case stream emitting elements faster than queue pulling them.
Reactive Streams semantics
cancels when SinkQueue.cancel
is called
backpressures when buffer has some space