akka.stream.javadsl

Interface SinkQueue<T>

All Known Subinterfaces:

SinkQueueWithCancel<T>

All Known Implementing Classes:

SinkQueueAdapter

public interface SinkQueue<T>

Trait allows to have the queue as a sink for some stream. "SinkQueue" pulls data from stream with backpressure mechanism.

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.CompletionStage<java.util.Optional<T>>	pull() Method pulls elements from stream and returns future that: - fails if stream is failed - completes with None in case if stream is completed - completes with Some(element) in case next element is available from stream.

Method Detail

pull

java.util.concurrent.CompletionStage<java.util.Optional<T>> pull()

Method pulls elements from stream and returns future that: - fails if stream is failed - completes with None in case if stream is completed - completes with Some(element) in case next element is available from stream.

Returns:

(undocumented)