Sink.queue

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

Sink stages

Signature

def queue[T](): Sink[T, SinkQueueWithCancel[T]]

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

Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.