AsyncCollectionExtensions

WhereAwait``1

public static IAsyncEnumerable<T> WhereAwait<T>(IAsyncEnumerable<T> source, Func<T, CancellationToken, ValueTask<bool>> predicate, CancellationToken cancellationToken)

result = AsyncCollectionExtensions.WhereAwait(source, predicate, cancellationToken)

Filters an async sequence using an asynchronous predicate with cancellation support.