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 stream with a backpressure mechanism.
    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      java.util.concurrent.CompletionStage<java.util.Optional<T>> pull()
      Pulls elements from the stream and returns a CompletionStage that: - fails if the stream is failed - completes with Empty in case the stream is completed - completes with element in case the next element is available from the stream.
    • Method Detail

      • pull

        java.util.concurrent.CompletionStage<java.util.Optional<T>> pull()
        Pulls elements from the stream and returns a CompletionStage that: - fails if the stream is failed - completes with Empty in case the stream is completed - completes with element in case the next element is available from the stream.