ISinkQueueT Interface |
Namespace: Akka.Streams
The ISinkQueueT type exposes the following members.
Name | Description | |
---|---|---|
PullAsync |
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. |