ParallelAsyncIterator<TSource, TResult>

Namespace: SnowBank.Linq.Async.Iterators · class

Implements: AsyncFilterIterator<TSource, TResult>, IAsyncLinqQuery<TResult>, IAsyncQuery<TResult>, IAsyncEnumerable<TResult>, IAsyncEnumerator<TResult>, IAsyncDisposable

[EXPERIMENTAL] Iterates over an async sequence of items, kick off an async task in parallel, and returning the results in order

Constructors

ParallelAsyncIterator<TSource, TResult>

ParallelAsyncIterator<TSource, TResult>(IAsyncQuery<TSource> source, Func<TSource, CancellationToken, Task<TResult>> taskSelector, ParallelAsyncQueryOptions options)

Methods

DisposeAsync

ValueTask DisposeAsync()

Fields

DefaultMaxConcurrency

const int DefaultMaxConcurrency

Default max concurrency when doing batch queries

TODO: this is a placeholder value !