Click or drag to resize
Akka.NETISourceQueueWithCompleteT Interface

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

Type Parameters

T
TBD

The ISourceQueueWithCompleteT type exposes the following members.

Methods
  NameDescription
Public methodComplete
Complete the stream normally. Use WatchCompletionAsync to be notified of this operation’s success.
Public methodFail
Complete the stream with a failure. Use WatchCompletionAsync to be notified of this operation’s success.
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.

(Inherited from ISourceQueueT.)
Public methodWatchCompletionAsync
Method returns task that completes when stream is completed and fails when stream failed.
(Inherited from ISourceQueueT.)
Top
See Also