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

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method 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)