AsyncLinqExtensions.

ReduceAsync<TSource, TAccumulate, TResult>(IAsyncEnumerable<TSource>, TAccumulate, Func<TAccumulate, TSource, TAccumulate>, Func<TAccumulate, TResult>) Method

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)

Remarks

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.

Return Value

Type Description
ValueTask<TResult> An async sequence containing a single element with the final accumulator value.