| ISinkQueueTPullAsync Method |
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.
Namespace:
Akka.Streams
Assembly:
Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)
Syntax Task<Option<T>> PullAsync()
abstract PullAsync : unit -> Task<Option<'T>>
Return Value
Type:
TaskOptionTTBD
See Also