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>

Constructor Summary

Constructors

Constructor and Description
SinkQueueAdapter(SinkQueueWithCancel<T> delegate) INTERNAL API

Method Summary

Modifier and Type	Method and 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 with Some(element) in case next element is available from stream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SinkQueueAdapter

public SinkQueueAdapter(SinkQueueWithCancel<T> delegate)

INTERNAL API

Parameters:

delegate - (undocumented)

Method Detail

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 with Some(element) in case next element is available from stream.

Specified by:

pull in interface SinkQueue<T>

Returns:

(undocumented)

cancel

public void cancel()

Description copied from interface: SinkQueueWithCancel

Cancel the stream.

Specified by:

cancel in interface SinkQueueWithCancel<T>