SinkQueue

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.