akka.stream.scaladsl

Interface SinkQueue<T>

All Known Subinterfaces:

SinkQueueWithCancel<T>

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
scala.concurrent.Future<scala.Option<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

scala.concurrent.Future<scala.Option<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)