Interface ISinkQueue<T>
Trait allows to have the queue as a sink for some stream. "SinkQueue" pulls data from stream with backpressure mechanism.
Namespace: Akka.Streams
Assembly: Akka.Streams.dll
Syntax
public interface ISinkQueue<T>Type Parameters
| Name | Description |
|---|---|
| T | TBD |
Methods
| Improve this Doc View SourcePullAsync()
Method pulls elements from stream and returns task that:
- fails if stream is finished
- completes with None in case if stream is completed after we got task
- completes with Some(element) in case next element is available from stream.
Declaration
Task<Option<T>> PullAsync()Returns
| Type | Description |
|---|---|
| Task<Option<T>> | TBD |
Improve this Doc