Class StreamsAsyncEnumerableRerunnable<T, TMat>

Used to treat an IRunnableGraph<TMat> of ISinkQueue<T> as an IAsyncEnumerable<T>

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

Constructors

| Edit this page View Source

StreamsAsyncEnumerableRerunnable(Source<T, TMat>, IMaterializer)

Declaration
public StreamsAsyncEnumerableRerunnable(Source<T, TMat> source, IMaterializer materializer)
Parameters
Type Name Description
Source<T, TMat> source
IMaterializer materializer
| Edit this page View Source

StreamsAsyncEnumerableRerunnable(Source<T, TMat>, IMaterializer, int, int)

Declaration
public StreamsAsyncEnumerableRerunnable(Source<T, TMat> source, IMaterializer materializer, int minBuf, int maxBuf)
Parameters
Type Name Description
Source<T, TMat> source
IMaterializer materializer
int minBuf
int maxBuf

Methods

| Edit this page View Source

GetAsyncEnumerator(CancellationToken)

Returns an enumerator that iterates asynchronously through the collection.

Declaration
public IAsyncEnumerator<T> GetAsyncEnumerator(CancellationToken cancellationToken)
Parameters
Type Name Description
CancellationToken cancellationToken

A CancellationToken that may be used to cancel the asynchronous iteration.
Returns
Type Description
IAsyncEnumerator<T>

An enumerator that can be used to iterate asynchronously through the collection.

Implements

Extension Methods