AsyncLinqExtensions Class

Summary

AsyncLinqExtensions.
Assembly
Rocket.Surgery.Linq.Extensions.dll
Namespace
System.Linq
Base Types
  • Object
graph BT Type-->Base0["Object"] Type["AsyncLinqExtensions"] class Type type-node

Syntax

public static class AsyncLinqExtensions

Attributes

Type Description
NullableContextAttribute
NullableAttribute
PublicAPIAttribute

Methods

Name Value Summary
Filter<TSource>(IAsyncEnumerable<TSource>, Func<TSource, bool>) IAsyncEnumerable<TSource>
Filters a sequence of values based on a predicate.
static
Filter<TSource>(IAsyncEnumerable<TSource>, Func<TSource, int, bool>) IAsyncEnumerable<TSource>
Filters a sequence of values based on a predicate. Each element's index is used in the logic of the predicate function.
static
Map<TSource, TResult>(IAsyncEnumerable<TSource>, Func<TSource, int, TResult>) IAsyncEnumerable<TResult>
Projects each element of a sequence into a new form by incorporating the element's index.
static
Map<TSource, TResult>(IAsyncEnumerable<TSource>, Func<TSource, TResult>) IAsyncEnumerable<TResult>
Projects each element of a sequence into a new form.
static
MergeMap<TSource, TCollection, TResult>(IAsyncEnumerable<TSource>, Func<TSource, IAsyncEnumerable<TCollection>>, Func<TSource, TCollection, TResult>) IAsyncEnumerable<TResult>
Projects each element of a sequence to an System.Collections.Generic.IAsyncEnumerable`1, flattens the resulting sequences into one sequence, and invokes a result selector function on each element therein.
static
MergeMap<TSource, TCollection, TResult>(IAsyncEnumerable<TSource>, Func<TSource, int, IAsyncEnumerable<TCollection>>, Func<TSource, TCollection, TResult>) IAsyncEnumerable<TResult>
Projects each element of a sequence to an System.Collections.Generic.IAsyncEnumerable`1, flattens the resulting sequences into one sequence, and invokes a result selector function on each element therein. The index of each source element is used in the intermediate projected form of that element.
static
MergeMap<TSource, TResult>(IAsyncEnumerable<TSource>, Func<TSource, IAsyncEnumerable<TResult>>) IAsyncEnumerable<TResult>
Projects each element of a sequence to an System.Collections.Generic.IAsyncEnumerable`1 and flattens the resulting sequences into one sequence.
static
MergeMap<TSource, TResult>(IAsyncEnumerable<TSource>, Func<TSource, int, IAsyncEnumerable<TResult>>) IAsyncEnumerable<TResult>
Projects each element of a sequence to an System.Collections.Generic.IAsyncEnumerable`1, and flattens the resulting sequences into one sequence. The index of each source element is used in the projected form of that element.
static
ReduceAsync<TSource, TAccumulate, TResult>(IAsyncEnumerable<TSource>, TAccumulate, Func<TAccumulate, TSource, TAccumulate>, Func<TAccumulate, TResult>, CancellationToken) ValueTask<TResult>
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.
static
ReduceAsync<TSource, TAccumulate, TResult>(IAsyncEnumerable<TSource>, TAccumulate, Func<TAccumulate, TSource, TAccumulate>, Func<TAccumulate, TResult>) ValueTask<TResult>
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.
static
ReduceAsync<TSource, TAccumulate>(IAsyncEnumerable<TSource>, TAccumulate, Func<TAccumulate, TSource, TAccumulate>, CancellationToken) ValueTask<TAccumulate>
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. For aggregation behavior with incremental intermediate results.
static
ReduceAsync<TSource, TAccumulate>(IAsyncEnumerable<TSource>, TAccumulate, Func<TAccumulate, TSource, TAccumulate>) ValueTask<TAccumulate>
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. For aggregation behavior with incremental intermediate results.
static
ReduceAsync<TSource>(IAsyncEnumerable<TSource>, Func<TSource, TSource, TSource>, CancellationToken) ValueTask<TSource>
Applies an accumulator function over an async sequence, returning the result of the aggregation as a single element in the result sequence. For aggregation behavior with incremental intermediate results.
static
ReduceAsync<TSource>(IAsyncEnumerable<TSource>, Func<TSource, TSource, TSource>) ValueTask<TSource>
Applies an accumulator function over an async sequence, returning the result of the aggregation as a single element in the result sequence. For aggregation behavior with incremental intermediate results.
static