public interface SinkQueue<T>
Modifier and Type | Method and 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. |
java.util.concurrent.CompletionStage<java.util.Optional<T>> pull()
Some(element)
in case next element is available from stream.