Summary
Applies an accumulator function over an async sequence, returning the result of the aggregation as a single element in the result sequence. The specified seed value is used as the initial accumulator value,
and the specified result selector function is used to select the result value.
Syntax
public static ValueTask<TResult> ReduceAsync<TSource, TAccumulate, TResult>(this IAsyncEnumerable<TSource> source, TAccumulate seed, Func<TAccumulate, TSource, TAccumulate> accumulator, Func<TAccumulate, TResult> resultSelector, CancellationToken cancellationToken)
The return type of this operator differs from the corresponding operator on IAsyncEnumerable in order to retain asynchronous behavior.
Type Parameters
| Name |
Description |
| TSource |
The type of the elements in the source sequence. |
| TAccumulate |
The type of the accumulator value. |
| TResult |
The type of the resulting value. |
Parameters
| Name |
Type |
Description |
| source |
IAsyncEnumerable<TSource> |
An async sequence to aggregate over. |
| seed |
TAccumulate |
The initial accumulator value. |
| accumulator |
Func<TAccumulate, TSource, TAccumulate> |
An accumulator function to be invoked on each element. |
| resultSelector |
Func<TAccumulate, TResult> |
A function to transform the final accumulator value into the result value. |
| cancellationToken |
CancellationToken |
The cancelation token |
Return Value
| Type |
Description |
| ValueTask<TResult> |
An async sequence containing a single element with the final accumulator value. |
