SinkQueueAdapter

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 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)
```
- Method Detail
  - cancel
```
public void cancel()
```
    Description copied from interface: SinkQueueWithCancel
    
    Cancel the stream.
    
    Specified by:
    
    cancel in interface SinkQueueWithCancel<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 with Some(element) in case next element is available from stream.
    
    Specified by:
    
    pull in interface SinkQueue<T>
    
    Returns:
    
    (undocumented)