Package akka.stream.impl
Class SinkQueueAdapter<T>
- java.lang.Object
-
- akka.stream.impl.SinkQueueAdapter<T>
-
- All Implemented Interfaces:
SinkQueue<T>
,SinkQueueWithCancel<T>
public final class SinkQueueAdapter<T> extends java.lang.Object implements SinkQueueWithCancel<T>
INTERNAL API
-
-
Constructor Summary
Constructors Constructor Description SinkQueueAdapter(SinkQueueWithCancel<T> delegate)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cancel()
Cancel the stream.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.
-
-
-
Constructor Detail
-
SinkQueueAdapter
public SinkQueueAdapter(SinkQueueWithCancel<T> delegate)
-
-
Method Detail
-
cancel
public void cancel()
Description copied from interface:SinkQueueWithCancel
Cancel the stream.- Specified by:
cancel
in interfaceSinkQueueWithCancel<T>
-
pull
public java.util.concurrent.CompletionStage<java.util.Optional<T>> pull()
Description copied from interface:SinkQueue
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.
-
-