ISourceQueueWithComplete(T) Interface

ISourceQueueWithCompleteT Interface

This interface adds completion support to ISourceQueueT

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 ISourceQueueWithComplete<'T> =  
    interface
        interface ISourceQueue<'T>
    end

The ISourceQueueWithCompleteT type exposes the following members.

Methods

	Name	Description
	Complete	Complete the stream normally. Use WatchCompletionAsync to be notified of this operation’s success.
	Fail	Complete the stream with a failure. Use WatchCompletionAsync to be notified of this operation’s success.
	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. (Inherited from ISourceQueueT.)
	WatchCompletionAsync	Method returns task that completes when stream is completed and fails when stream failed. (Inherited from ISourceQueueT.)