Click or drag to resize
Akka.NETISinkQueueT Interface
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 (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)
Syntax
public interface ISinkQueue<T>

Type Parameters

T
TBD

The ISinkQueueT type exposes the following members.

Methods
  NameDescription
Public methodPullAsync
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.

Top
See Also