Package akka.stream.javadsl
Interface SinkQueue<T>
-
- 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 withSome(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 withSome(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 withSome(element)
in case next element is available from stream.- Returns:
- (undocumented)
-
-