SinkQueue

All Known Subinterfaces:

SinkQueueWithCancel<T>

All Known Implementing Classes:

SinkQueueAdapter
```
public interface SinkQueue<T>
```
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 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)