Akka Documentation

Version 2.10.4+3-f7095f01-SNAPSHOT

This documentation regards version 2.10.4+3-f7095f01-SNAPSHOT, however the current version is 2.10.4.

Sink.queue

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

Sink operators

Signature

Sink.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

Source.queue
Source.range
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.