Click or drag to resize
Akka.NETISourceQueueT Interface
This interface allows to have the queue as a data source for some stream.

Namespace:  Akka.Streams
Assembly:  Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)
Syntax
public interface ISourceQueue<in T>

Type Parameters

T
TBD

The ISourceQueueT type exposes the following members.

Methods
  NameDescription
Public methodOfferAsync
Method offers next element to a stream and returns task that:

- competes with QueueOfferResultEnqueued if element is consumed by a stream

- competes with QueueOfferResultDropped when stream dropped offered element

- competes with QueueOfferResultQueueClosed when stream is completed while task is active

- competes with QueueOfferResultFailure when failure to enqueue element from upstream

- fails if stream is completed or you cannot call offer in this moment because of implementation rules (like for backpressure mode and full buffer you need to wait for last offer call task completion.

Public methodWatchCompletionAsync
Method returns task that completes when stream is completed and fails when stream failed.
Top
See Also