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