Interface ISourceQueueWithComplete<T>

This interface adds completion support to ISourceQueue<T>

Inherited Members
Namespace: Akka.Streams
Assembly: Akka.Streams.dll
Syntax
public interface ISourceQueueWithComplete<in T> : ISourceQueue<T>
Type Parameters
Name Description
T

TBD

Methods

| Improve this Doc View Source

Complete()

Complete the stream normally. Use WatchCompletionAsync() to be notified of this operation’s success.

Declaration
void Complete()
| Improve this Doc View Source

Fail(Exception)

Complete the stream with a failure. Use WatchCompletionAsync() to be notified of this operation’s success.

Declaration
void Fail(Exception ex)
Parameters
Type Name Description
Exception ex

TBD
| Improve this Doc View Source

WatchCompletionAsync()

Method returns Task that will be completed if the stream completes, or will be failed when the stage faces an internal failure or the the Fail(Exception) method is invoked.

Declaration
Task WatchCompletionAsync()
Returns
Type Description
Task

Task

Extension Methods