Class SinkQueueAsyncEnumerator<T>

Wraps a Sink Queue and Killswitch around IAsyncEnumerator<T>

Inheritance
object
SinkQueueAsyncEnumerator<T>
Implements
Inherited Members
Namespace: Akka.Streams.Dsl
Assembly: Akka.Streams.dll
Syntax
public sealed class SinkQueueAsyncEnumerator<T> : IAsyncEnumerator<T>, IAsyncDisposable
Type Parameters
Name Description
T

Constructors

| Edit this page View Source

SinkQueueAsyncEnumerator((UniqueKillSwitch killSwitch, ISinkQueue<T> sinkQueue), CancellationToken)

Declaration
public SinkQueueAsyncEnumerator((UniqueKillSwitch killSwitch, ISinkQueue<T> sinkQueue) queueAndSwitch, CancellationToken token)
Parameters
Type Name Description
(UniqueKillSwitch killSwitch, ISinkQueue<T> sinkQueue) queueAndSwitch
CancellationToken token

Properties

| Edit this page View Source

Current

Gets the element in the collection at the current position of the enumerator.

Declaration
public T Current { get; }
Property Value
Type Description
T

Methods

| Edit this page View Source

DisposeAsync()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources asynchronously.

Declaration
public ValueTask DisposeAsync()
Returns
Type Description
ValueTask
| Edit this page View Source

MoveNextAsync()

Advances the enumerator asynchronously to the next element of the collection.

Declaration
public ValueTask<bool> MoveNextAsync()
Returns
Type Description
ValueTask<bool>

A ValueTask<TResult> that will complete with a result of true if the enumerator was successfully advanced to the next element, or false if the enumerator has passed the end of the collection.

Implements

Extension Methods