Share via


AsyncEnumerableExtensions Class

Definition

Provides extension methods for IAsyncEnumerable<T> to enable advanced streaming operations.

public static class AsyncEnumerableExtensions
type AsyncEnumerableExtensions = class
Public Module AsyncEnumerableExtensions
Inheritance
AsyncEnumerableExtensions

Methods

Name Description
ChunkByKey<TSource,TKey>(IAsyncEnumerable<TSource>, Func<TSource,TKey>, IEqualityComparer<TKey>, CancellationToken)

Chunks the async enumerable sequence into groups based on a key selector function.

ChunkOnChange<TSource>(IAsyncEnumerable<TSource>, Func<TSource,TSource,Boolean>, CancellationToken)

Chunks the async enumerable sequence into groups based on when consecutive elements change.

Peek<T>(IAsyncEnumerable<T>, CancellationToken)

Peeks at the first element of an async enumerable sequence without consuming the sequence.

Applies to