Sink.queue

Materialize a SinkQueue that can be pulled to trigger demand through the sink.

Sink operators

Signature

Sink.queueSink.queue

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