Click or drag to resize
Akka.NETISourceQueueTOfferAsync Method
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.

Namespace:  Akka.Streams
Assembly:  Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)
Syntax
Task<IQueueOfferResult> OfferAsync(
	T element
)

Parameters

element
Type: T
element to send to a stream

Return Value

Type: TaskIQueueOfferResult
TBD
See Also