Class StreamsAsyncEnumerableRerunnable<T, TMat>
Inheritance
StreamsAsyncEnumerableRerunnable<T, TMat>
Implements
System.Collections.Generic.IAsyncEnumerable<T>
Assembly: Akka.Streams.dll
Syntax
public sealed class StreamsAsyncEnumerableRerunnable<T, TMat> : IAsyncEnumerable<T>
Type Parameters
Constructors
|
Improve this Doc
View Source
StreamsAsyncEnumerableRerunnable(Source<T, TMat>, IMaterializer)
Declaration
public StreamsAsyncEnumerableRerunnable(Source<T, TMat> source, IMaterializer materializer)
Parameters
|
Improve this Doc
View Source
StreamsAsyncEnumerableRerunnable(Source<T, TMat>, IMaterializer, Int32, Int32)
Declaration
public StreamsAsyncEnumerableRerunnable(Source<T, TMat> source, IMaterializer materializer, int minBuf, int maxBuf)
Parameters
Methods
|
Improve this Doc
View Source
GetAsyncEnumerator(CancellationToken)
Declaration
public IAsyncEnumerator<T> GetAsyncEnumerator(CancellationToken cancellationToken)
Parameters
Returns
Type |
Description |
System.Collections.Generic.IAsyncEnumerator<T> |
|
Implements
System.Collections.Generic.IAsyncEnumerable<T>
Extension Methods