Package org.apache.pekko.stream.scaladsl

Interface SinkQueue<T>

All Known Subinterfaces:
SinkQueueWithCancel<T>
public interface SinkQueue<T>
This trait allows to have a queue as a sink for a stream. A SinkQueue pulls data from a stream with a backpressure mechanism.

  • Method Summary

    Modifier and Type
    Method
    Description
    scala.concurrent.Future<scala.Option<T>>
    pull()
    Pulls elements from the stream and returns a Future that: - fails if the stream is failed - completes with None in case the stream is completed - completes with Some(element) in case the next element is available from stream.

  • Method Details

    • pull

      scala.concurrent.Future<scala.Option<T>> pull()
      Pulls elements from the stream and returns a Future that: - fails if the stream is failed - completes with None in case the stream is completed - completes with Some(element) in case the next element is available from stream.