 | ISourceQueueT 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)
SyntaxThe ISourceQueueT type exposes the following members.
Methods| Name | Description | |
|---|---|---|
 | OfferAsync |
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. |
| WatchCompletionAsync |
Method returns task that completes when stream is completed and fails
when stream failed.
|
See Also