ISinkQueue(T) Interface

ISinkQueueT 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.42 (1.2.3.42)

Syntax

public interface ISinkQueue<T>

type ISinkQueue<'T> =  interface end

The ISinkQueueT type exposes the following members.

Methods

	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.