Class SinkQueueAsyncEnumerator<T>

Wraps a Sink Queue and Killswitch around System.Collections.Generic.IAsyncEnumerator<T>

Inheritance
Object
SinkQueueAsyncEnumerator<T>
Implements
System.Collections.Generic.IAsyncEnumerator<T>
System.IAsyncDisposable
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

| Improve this Doc View Source

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

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

Properties

| Improve this Doc View Source

Current

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

Methods

| Improve this Doc View Source

DisposeAsync()

Declaration
public ValueTask DisposeAsync()
Returns
Type Description
System.Threading.Tasks.ValueTask
| Improve this Doc View Source

MoveNextAsync()

Declaration
public async ValueTask<bool> MoveNextAsync()
Returns
Type Description
System.Threading.Tasks.ValueTask<Boolean>

Implements

System.Collections.Generic.IAsyncEnumerator<T>
System.IAsyncDisposable

Extension Methods