<PackageReference Include="AsyncEnumerator" Version="4.0.1" />

---

API Differences between 4.0.1 and 3.1.0

125 Additions 141 Removals

Dasync.Collections

• public abstract class AsyncEnumerable : IAsyncEnumerable
  • public static IAsyncEnumerable<T> Empty<T>()
  • public static IAsyncEnumerable<T> Empty<T>()
• public class AsyncEnumerable<T> : AsyncEnumerable, IAsyncEnumerable, IAsyncEnumerable<T>
  • public static readonly IAsyncEnumerable<T> Empty
  • public static readonly IAsyncEnumerable<T> Empty
  • public IAsyncEnumerator<T> GetAsyncEnumerator(CancellationToken cancellationToken = default)
  • public IAsyncEnumerator<T> GetAsyncEnumerator(CancellationToken cancellationToken = default)
• public static class AsyncEnumerableAdapterExtensions
  • public static IEnumerator GetEnumerator(this IAsyncEnumerable asyncEnumerable)
  • public static IEnumerator<T> GetEnumerator<T>(this IAsyncEnumerable<T> asyncEnumerable)
  • public static bool MoveNext(this IAsyncEnumerator asyncEnumerator)
  • public static IEnumerable ToEnumerable(this IAsyncEnumerable asyncEnumerable)
  • public static IEnumerable<T> ToEnumerable<T>(this IAsyncEnumerable<T> asyncEnumerable)
  • public static IEnumerator ToEnumerator(this IAsyncEnumerator asyncEnumerator)
  • public static IEnumerator<T> ToEnumerator<T>(this IAsyncEnumerator<T> asyncEnumerator)
  • public static IEnumerator<T> GetEnumerator<T>(this IAsyncEnumerable<T> asyncEnumerable)
  • public static IEnumerable<T> ToEnumerable<T>(this IAsyncEnumerable<T> asyncEnumerable)
  • public static IEnumerator<T> ToEnumerator<T>(this IAsyncEnumerator<T> asyncEnumerator)
• public class AsyncEnumerableWithState<TItem, TState> : AsyncEnumerable, IAsyncEnumerable, IAsyncEnumerable<TItem>
  • public virtual IAsyncEnumerator<TItem> GetAsyncEnumerator(CancellationToken cancellationToken = default)
  • public virtual IAsyncEnumerator<TItem> GetAsyncEnumerator(CancellationToken cancellationToken = default)
• public abstract class AsyncEnumerator
  • public static IAsyncEnumerator<T> Empty<T>()
  • public static IAsyncEnumerator<T> Empty<T>()
• public class AsyncEnumerator<T> : AsyncEnumeratorWithState<T, NoStateAdapter<T>>
  • public static readonly IAsyncEnumerator<T> Empty
  • public static readonly IAsyncEnumerator<T> Empty
• public static class EnumerableExtensions
• public static class ForEachAsyncExtensions
  • public static Task ForEachAsync(this IAsyncEnumerable enumerable, Action<object> action, CancellationToken cancellationToken = default)
  • public static Task ForEachAsync(this IAsyncEnumerator enumerator, Action<object> action)
  • public static Task ForEachAsync(this IAsyncEnumerable enumerable, Action<object, long> action, CancellationToken cancellationToken = default)
  • public static Task ForEachAsync(this IAsyncEnumerator enumerator, Action<object, long> action)
  • public static Task ForEachAsync(this IAsyncEnumerable enumerable, Func<object, Task> action, CancellationToken cancellationToken = default)
  • public static Task ForEachAsync(this IAsyncEnumerator enumerator, Func<object, Task> action)
  • public static Task ForEachAsync(this IAsyncEnumerable enumerable, Func<object, long, Task> action, CancellationToken cancellationToken = default)
  • public static Task ForEachAsync(this IAsyncEnumerator enumerator, Func<object, long, Task> action)
  • public static Task ForEachAsync<T>(this IAsyncEnumerable<T> enumerable, Action<T> action, CancellationToken cancellationToken = default)
  • public static Task ForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Action<T> action)
  • public static Task ForEachAsync<T>(this IAsyncEnumerable<T> enumerable, Action<T, long> action, CancellationToken cancellationToken = default)
  • public static Task ForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Action<T, long> action)
  • public static Task ForEachAsync<T>(this IAsyncEnumerable<T> enumerable, Func<T, Task> action, CancellationToken cancellationToken = default)
  • public static Task ForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, Task> action)
  • public static Task ForEachAsync<T>(this IAsyncEnumerable<T> enumerable, Func<T, long, Task> action, CancellationToken cancellationToken = default)
  • public static Task ForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, long, Task> action)
  • public static Task ForEachAsync<T>(this IAsyncEnumerable<T> enumerable, Action<T> action, CancellationToken cancellationToken = default)
  • public static Task ForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Action<T> action)
  • public static Task ForEachAsync<T>(this IAsyncEnumerable<T> enumerable, Action<T, long> action, CancellationToken cancellationToken = default)
  • public static Task ForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Action<T, long> action)
  • public static Task ForEachAsync<T>(this IAsyncEnumerable<T> enumerable, Func<T, Task> action, CancellationToken cancellationToken = default)
  • public static Task ForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, Task> action)
  • public static Task ForEachAsync<T>(this IAsyncEnumerable<T> enumerable, Func<T, long, Task> action, CancellationToken cancellationToken = default)
  • public static Task ForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, long, Task> action)
• public static class GenericEnumerableExtensions
  • public static IAsyncEnumerator<T> GetAsyncEnumerator<T>(this IEnumerable<T> enumerable, bool runSynchronously = true)
  • public static IAsyncEnumerable<T> ToAsyncEnumerable<T>(this IEnumerable<T> enumerable, bool runSynchronously = true)
  • public static IAsyncEnumerator<T> ToAsyncEnumerator<T>(this IEnumerator<T> enumerator, bool runSynchronously = true)
  • public static IAsyncEnumerator<T> GetAsyncEnumerator<T>(this IEnumerable<T> enumerable, bool runSynchronously = true)
  • public static IAsyncEnumerable<T> ToAsyncEnumerable<T>(this IEnumerable<T> enumerable, bool runSynchronously = true)
  • public static IAsyncEnumerator<T> ToAsyncEnumerator<T>(this IEnumerator<T> enumerator, bool runSynchronously = true)
• public interface IAsyncDisposable
• public interface IAsyncEnumerable<T> : IAsyncEnumerable
• public static class IAsyncEnumerableExtensions
  • public static Task<TSource> AggregateAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, TSource, TSource> func, CancellationToken cancellationToken = default)
  • public static Task<TAccumulate> AggregateAsync<TSource, TAccumulate>(this IAsyncEnumerable<TSource> source, TAccumulate seed, Func<TAccumulate, TSource, TAccumulate> func, CancellationToken cancellationToken = default)
  • public static Task<TResult> AggregateAsync<TSource, TAccumulate, TResult>(this IAsyncEnumerable<TSource> source, TAccumulate seed, Func<TAccumulate, TSource, TAccumulate> func, Func<TAccumulate, TResult> resultSelector, CancellationToken cancellationToken = default)
  • public static IAsyncEnumerable<TSource> Append<TSource>(this IAsyncEnumerable<TSource> source, TSource element)
  • public static IAsyncEnumerable<List<TSource>> Batch<TSource>(this IAsyncEnumerable<TSource> source, int batchSize)
  • public static IAsyncEnumerable<TStandardCollection> Batch<TSource, TStandardCollection>(this IAsyncEnumerable<TSource> source, int batchSize)
  • public static IAsyncEnumerable<List<TSource>> Batch<TSource>(this IAsyncEnumerable<TSource> source, long maxBatchWeight, Func<TSource, long> weightSelector)
  • public static IAsyncEnumerable<TStandardCollection> Batch<TSource, TStandardCollection>(this IAsyncEnumerable<TSource> source, long maxBatchWeight, Func<TSource, long> weightSelector)
  • public static IAsyncEnumerable<List<TSource>> Batch<TSource>(this IAsyncEnumerable<TSource> source, int maxItemsInBatch, long maxBatchWeight, Func<TSource, long> weightSelector)
  • public static IAsyncEnumerable<TStandardCollection> Batch<TSource, TStandardCollection>(this IAsyncEnumerable<TSource> source, int maxItemsInBatch, long maxBatchWeight, Func<TSource, long> weightSelector)
  • public static IAsyncEnumerable<TBatch> Batch<TSource, TBatch>(this IAsyncEnumerable<TSource> source, int? maxItemsInBatch, long maxBatchWeight, Func<TSource, long> weightSelector, Func<int?, TBatch> createBatch, Action<TBatch, TSource> addItem)
  • public static IAsyncEnumerable<TResult> Cast<TResult>(this IAsyncEnumerable source)
  • public static IAsyncEnumerable<TSource> Concat<TSource>(this IAsyncEnumerable<TSource> first, IAsyncEnumerable<TSource> second)
  • public static IAsyncEnumerable<TSource> DefaultIfEmpty<TSource>(this IAsyncEnumerable<TSource> source)
  • public static IAsyncEnumerable<TSource> DefaultIfEmpty<TSource>(this IAsyncEnumerable<TSource> source, TSource defaultValue)
  • public static IAsyncEnumerable<TSource> Distinct<TSource>(this IAsyncEnumerable<TSource> source)
  • public static IAsyncEnumerable<TSource> Distinct<TSource>(this IAsyncEnumerable<TSource> source, IEqualityComparer<TSource> comparer)
  • public static Task<TSource> FirstAsync<TSource>(this IAsyncEnumerable<TSource> source, CancellationToken token = default)
  • public static Task<TSource> FirstAsync<TSource>(this IAsyncEnumerable<TSource> source, string exceptionMessage, CancellationToken token = default)
  • public static Task<TSource> FirstAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate, CancellationToken token = default)
  • public static Task<TSource> FirstAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate, string exceptionMessage, CancellationToken token = default)
  • public static Task<TSource> FirstOrDefaultAsync<TSource>(this IAsyncEnumerable<TSource> source, CancellationToken token = default)
  • public static Task<TSource> FirstOrDefaultAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate, CancellationToken token = default)
  • public static IAsyncEnumerable<TResult> OfType<TResult>(this IAsyncEnumerable source)
  • public static IAsyncEnumerable<TSource> Prepend<TSource>(this IAsyncEnumerable<TSource> source, TSource element)
  • public static IAsyncEnumerable<TResult> Select<TSource, TResult>(this IAsyncEnumerable<TSource> source, Func<TSource, TResult> selector)
  • public static IAsyncEnumerable<TResult> Select<TSource, TResult>(this IAsyncEnumerable<TSource> source, Func<TSource, long, TResult> selector)
  • public static IAsyncEnumerable<TResult> SelectMany<TSource, TResult>(this IAsyncEnumerable<TSource> source, Func<TSource, IAsyncEnumerable<TResult>> selector)
  • public static IAsyncEnumerable<TResult> SelectMany<TSource, TItem, TResult>(this IAsyncEnumerable<TSource> source, Func<TSource, IAsyncEnumerable<TItem>> collectionSelector, Func<TSource, TItem, TResult> resultSelector)
  • public static IAsyncEnumerable<TResult> SelectMany<TSource, TResult>(this IAsyncEnumerable<TSource> source, Func<TSource, IEnumerable<TResult>> selector)
  • public static IAsyncEnumerable<TResult> SelectMany<TSource, TItem, TResult>(this IAsyncEnumerable<TSource> source, Func<TSource, IEnumerable<TItem>> collectionSelector, Func<TSource, TItem, TResult> resultSelector)
  • public static Task<TSource> SingleAsync<TSource>(this IAsyncEnumerable<TSource> source, CancellationToken token = default)
  • public static Task<TSource> SingleAsync<TSource>(this IAsyncEnumerable<TSource> source, string noneExceptionMessage, string manyExceptionMessage, CancellationToken token = default)
  • public static Task<TSource> SingleAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate, CancellationToken token = default)
  • public static Task<TSource> SingleAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate, string noneExceptionMessage, string manyExceptionMessage, CancellationToken token = default)
  • public static Task<TSource> SingleOrDefaultAsync<TSource>(this IAsyncEnumerable<TSource> source, CancellationToken token = default)
  • public static Task<TSource> SingleOrDefaultAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate, CancellationToken token = default)
  • public static IAsyncEnumerable<TSource> Skip<TSource>(this IAsyncEnumerable<TSource> source, int count)
  • public static IAsyncEnumerable<TSource> SkipWhile<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate)
  • public static IAsyncEnumerable<TSource> Take<TSource>(this IAsyncEnumerable<TSource> source, int count)
  • public static IAsyncEnumerable<TSource> TakeWhile<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate)
  • public static Task<T[]> ToArrayAsync<T>(this IAsyncEnumerable<T> source, CancellationToken cancellationToken = default)
  • public static Task<Dictionary<TKey, TSource>> ToDictionaryAsync<TSource, TKey>(this IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector, CancellationToken cancellationToken = default)
  • public static Task<Dictionary<TKey, TSource>> ToDictionaryAsync<TSource, TKey>(this IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer, CancellationToken cancellationToken = default)
  • public static Task<Dictionary<TKey, TElement>> ToDictionaryAsync<TSource, TKey, TElement>(this IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, CancellationToken cancellationToken = default)
  • public static Task<Dictionary<TKey, TElement>> ToDictionaryAsync<TSource, TKey, TElement>(this IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, IEqualityComparer<TKey> comparer, CancellationToken cancellationToken = default)
  • public static Task<List<T>> ToListAsync<T>(this IAsyncEnumerable<T> source, CancellationToken cancellationToken = default)
  • public static Task<ILookup<TKey, TSource>> ToLookupAsync<TSource, TKey>(this IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector, CancellationToken cancellationToken = default)
  • public static Task<ILookup<TKey, TSource>> ToLookupAsync<TSource, TKey>(this IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer, CancellationToken cancellationToken = default)
  • public static Task<ILookup<TKey, TElement>> ToLookupAsync<TSource, TKey, TElement>(this IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, CancellationToken cancellationToken = default)
  • public static Task<ILookup<TKey, TElement>> ToLookupAsync<TSource, TKey, TElement>(this IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, IEqualityComparer<TKey> comparer, CancellationToken cancellationToken = default)
  • public static IAsyncEnumerable<T> UnionAll<T>(this IAsyncEnumerable<T> first, IAsyncEnumerable<T> second)
  • public static IAsyncEnumerable<T> UnionAll<T>(this IEnumerable<IAsyncEnumerable<T>> collections)
  • public static IAsyncEnumerable<TSource> Where<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate)
  • public static IAsyncEnumerable<TSource> Where<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, long, bool> predicate)
  • public static Task<TSource> AggregateAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, TSource, TSource> func, CancellationToken cancellationToken = default)
  • public static Task<TAccumulate> AggregateAsync<TSource, TAccumulate>(this IAsyncEnumerable<TSource> source, TAccumulate seed, Func<TAccumulate, TSource, TAccumulate> func, CancellationToken cancellationToken = default)
  • public static Task<TResult> AggregateAsync<TSource, TAccumulate, TResult>(this IAsyncEnumerable<TSource> source, TAccumulate seed, Func<TAccumulate, TSource, TAccumulate> func, Func<TAccumulate, TResult> resultSelector, CancellationToken cancellationToken = default)
  • public static IAsyncEnumerable<TSource> Append<TSource>(this IAsyncEnumerable<TSource> source, TSource element)
  • public static IAsyncEnumerable<List<TSource>> Batch<TSource>(this IAsyncEnumerable<TSource> source, int batchSize)
  • public static IAsyncEnumerable<TStandardCollection> Batch<TSource, TStandardCollection>(this IAsyncEnumerable<TSource> source, int batchSize)
  • public static IAsyncEnumerable<List<TSource>> Batch<TSource>(this IAsyncEnumerable<TSource> source, long maxBatchWeight, Func<TSource, long> weightSelector)
  • public static IAsyncEnumerable<TStandardCollection> Batch<TSource, TStandardCollection>(this IAsyncEnumerable<TSource> source, long maxBatchWeight, Func<TSource, long> weightSelector)
  • public static IAsyncEnumerable<List<TSource>> Batch<TSource>(this IAsyncEnumerable<TSource> source, int maxItemsInBatch, long maxBatchWeight, Func<TSource, long> weightSelector)
  • public static IAsyncEnumerable<TStandardCollection> Batch<TSource, TStandardCollection>(this IAsyncEnumerable<TSource> source, int maxItemsInBatch, long maxBatchWeight, Func<TSource, long> weightSelector)
  • public static IAsyncEnumerable<TBatch> Batch<TSource, TBatch>(this IAsyncEnumerable<TSource> source, int? maxItemsInBatch, long maxBatchWeight, Func<TSource, long> weightSelector, Func<int?, TBatch> createBatch, Action<TBatch, TSource> addItem)
  • public static IAsyncEnumerable<TResult> Cast<TResult>(this IAsyncEnumerable source)
  • public static IAsyncEnumerable<TSource> Concat<TSource>(this IAsyncEnumerable<TSource> first, IAsyncEnumerable<TSource> second)
  • public static IAsyncEnumerable<TSource> DefaultIfEmpty<TSource>(this IAsyncEnumerable<TSource> source)
  • public static IAsyncEnumerable<TSource> DefaultIfEmpty<TSource>(this IAsyncEnumerable<TSource> source, TSource defaultValue)
  • public static IAsyncEnumerable<TSource> Distinct<TSource>(this IAsyncEnumerable<TSource> source)
  • public static IAsyncEnumerable<TSource> Distinct<TSource>(this IAsyncEnumerable<TSource> source, IEqualityComparer<TSource> comparer)
  • public static Task<TSource> FirstAsync<TSource>(this IAsyncEnumerable<TSource> source, CancellationToken token = default)
  • public static Task<TSource> FirstAsync<TSource>(this IAsyncEnumerable<TSource> source, string exceptionMessage, CancellationToken token = default)
  • public static Task<TSource> FirstAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate, CancellationToken token = default)
  • public static Task<TSource> FirstAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate, string exceptionMessage, CancellationToken token = default)
  • public static Task<TSource> FirstOrDefaultAsync<TSource>(this IAsyncEnumerable<TSource> source, CancellationToken token = default)
  • public static Task<TSource> FirstOrDefaultAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate, CancellationToken token = default)
  • public static IAsyncEnumerable<TResult> OfType<TResult>(this IAsyncEnumerable source)
  • public static IAsyncEnumerable<TSource> Prepend<TSource>(this IAsyncEnumerable<TSource> source, TSource element)
  • public static IAsyncEnumerable<TResult> Select<TSource, TResult>(this IAsyncEnumerable<TSource> source, Func<TSource, TResult> selector)
  • public static IAsyncEnumerable<TResult> Select<TSource, TResult>(this IAsyncEnumerable<TSource> source, Func<TSource, long, TResult> selector)
  • public static IAsyncEnumerable<TResult> SelectMany<TSource, TResult>(this IAsyncEnumerable<TSource> source, Func<TSource, IAsyncEnumerable<TResult>> selector)
  • public static IAsyncEnumerable<TResult> SelectMany<TSource, TItem, TResult>(this IAsyncEnumerable<TSource> source, Func<TSource, IAsyncEnumerable<TItem>> collectionSelector, Func<TSource, TItem, TResult> resultSelector)
  • public static IAsyncEnumerable<TResult> SelectMany<TSource, TResult>(this IAsyncEnumerable<TSource> source, Func<TSource, IEnumerable<TResult>> selector)
  • public static IAsyncEnumerable<TResult> SelectMany<TSource, TItem, TResult>(this IAsyncEnumerable<TSource> source, Func<TSource, IEnumerable<TItem>> collectionSelector, Func<TSource, TItem, TResult> resultSelector)
  • public static Task<TSource> SingleAsync<TSource>(this IAsyncEnumerable<TSource> source, CancellationToken token = default)
  • public static Task<TSource> SingleAsync<TSource>(this IAsyncEnumerable<TSource> source, string noneExceptionMessage, string manyExceptionMessage, CancellationToken token = default)
  • public static Task<TSource> SingleAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate, CancellationToken token = default)
  • public static Task<TSource> SingleAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate, string noneExceptionMessage, string manyExceptionMessage, CancellationToken token = default)
  • public static Task<TSource> SingleOrDefaultAsync<TSource>(this IAsyncEnumerable<TSource> source, CancellationToken token = default)
  • public static Task<TSource> SingleOrDefaultAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate, CancellationToken token = default)
  • public static IAsyncEnumerable<TSource> Skip<TSource>(this IAsyncEnumerable<TSource> source, int count)
  • public static IAsyncEnumerable<TSource> SkipWhile<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate)
  • public static IAsyncEnumerable<TSource> Take<TSource>(this IAsyncEnumerable<TSource> source, int count)
  • public static IAsyncEnumerable<TSource> TakeWhile<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate)
  • public static Task<T[]> ToArrayAsync<T>(this IAsyncEnumerable<T> source, CancellationToken cancellationToken = default)
  • public static Task<Dictionary<TKey, TSource>> ToDictionaryAsync<TSource, TKey>(this IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector, CancellationToken cancellationToken = default)
  • public static Task<Dictionary<TKey, TSource>> ToDictionaryAsync<TSource, TKey>(this IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer, CancellationToken cancellationToken = default)
  • public static Task<Dictionary<TKey, TElement>> ToDictionaryAsync<TSource, TKey, TElement>(this IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, CancellationToken cancellationToken = default)
  • public static Task<Dictionary<TKey, TElement>> ToDictionaryAsync<TSource, TKey, TElement>(this IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, IEqualityComparer<TKey> comparer, CancellationToken cancellationToken = default)
  • public static Task<List<T>> ToListAsync<T>(this IAsyncEnumerable<T> source, CancellationToken cancellationToken = default)
  • public static Task<ILookup<TKey, TSource>> ToLookupAsync<TSource, TKey>(this IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector, CancellationToken cancellationToken = default)
  • public static Task<ILookup<TKey, TSource>> ToLookupAsync<TSource, TKey>(this IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer, CancellationToken cancellationToken = default)
  • public static Task<ILookup<TKey, TElement>> ToLookupAsync<TSource, TKey, TElement>(this IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, CancellationToken cancellationToken = default)
  • public static Task<ILookup<TKey, TElement>> ToLookupAsync<TSource, TKey, TElement>(this IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, IEqualityComparer<TKey> comparer, CancellationToken cancellationToken = default)
  • public static IAsyncEnumerable<T> UnionAll<T>(this IAsyncEnumerable<T> first, IAsyncEnumerable<T> second)
  • public static IAsyncEnumerable<T> UnionAll<T>(this IEnumerable<IAsyncEnumerable<T>> collections)
  • public static IAsyncEnumerable<TSource> Where<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate)
  • public static IAsyncEnumerable<TSource> Where<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, long, bool> predicate)
• public interface IAsyncEnumerator<T> : IAsyncEnumerator, IDisposable, IAsyncDisposable
• public static class IAsyncEnumeratorExtensions
  • public static IAsyncEnumerator<List<TSource>> Batch<TSource>(this IAsyncEnumerator<TSource> source, int batchSize, bool disposeSource = true)
  • public static IAsyncEnumerator<TStandardCollection> Batch<TSource, TStandardCollection>(this IAsyncEnumerator<TSource> source, int batchSize, bool disposeSource = true)
  • public static IAsyncEnumerator<List<TSource>> Batch<TSource>(this IAsyncEnumerator<TSource> source, long maxBatchWeight, Func<TSource, long> weightSelector, bool disposeSource = true)
  • public static IAsyncEnumerator<TStandardCollection> Batch<TSource, TStandardCollection>(this IAsyncEnumerator<TSource> source, long maxBatchWeight, Func<TSource, long> weightSelector, bool disposeSource = true)
  • public static IAsyncEnumerator<List<TSource>> Batch<TSource>(this IAsyncEnumerator<TSource> source, int maxItemsInBatch, long maxBatchWeight, Func<TSource, long> weightSelector, bool disposeSource = true)
  • public static IAsyncEnumerator<TStandardCollection> Batch<TSource, TStandardCollection>(this IAsyncEnumerator<TSource> source, int maxItemsInBatch, long maxBatchWeight, Func<TSource, long> weightSelector, bool disposeSource = true)
  • public static IAsyncEnumerator<TBatch> Batch<TSource, TBatch>(this IAsyncEnumerator<TSource> source, int? maxItemsInBatch, long maxBatchWeight, Func<TSource, long> weightSelector, Func<int?, TBatch> createBatch, Action<TBatch, TSource> addItem, bool disposeSource = true)
  • public static IAsyncEnumerator<TResult> Cast<TResult>(this IAsyncEnumerator source, bool disposeSource = true)
  • public static IAsyncEnumerator<TSource> DefaultIfEmpty<TSource>(this IAsyncEnumerator<TSource> source, bool disposeSource = true)
  • public static IAsyncEnumerator<TSource> DefaultIfEmpty<TSource>(this IAsyncEnumerator<TSource> source, TSource defaultValue, bool disposeSource = true)
  • public static Task<TSource> FirstAsync<TSource>(this IAsyncEnumerator<TSource> source, bool disposeSource = true)
  • public static Task<TSource> FirstAsync<TSource>(this IAsyncEnumerator<TSource> source, string exceptionMessage, bool disposeSource = true)
  • public static Task<TSource> FirstAsync<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, bool> predicate, bool disposeSource = true)
  • public static Task<TSource> FirstAsync<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, bool> predicate, string exceptionMessage, bool disposeSource = true)
  • public static Task<TSource> FirstOrDefaultAsync<TSource>(this IAsyncEnumerator<TSource> source, bool disposeSource = true)
  • public static Task<TSource> FirstOrDefaultAsync<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, bool> predicate, bool disposeSource = true)
  • public static IAsyncEnumerator<TResult> Select<TSource, TResult>(this IAsyncEnumerator<TSource> source, Func<TSource, TResult> selector, bool disposeSource = true)
  • public static IAsyncEnumerator<TResult> Select<TSource, TResult>(this IAsyncEnumerator<TSource> source, Func<TSource, long, TResult> selector, bool disposeSource = true)
  • public static Task<TSource> SingleAsync<TSource>(this IAsyncEnumerator<TSource> source, bool disposeSource = true)
  • public static Task<TSource> SingleAsync<TSource>(this IAsyncEnumerator<TSource> source, string noneExceptionMessage, string manyExceptionMessage, bool disposeSource = true)
  • public static Task<TSource> SingleAsync<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, bool> predicate, bool disposeSource = true)
  • public static Task<TSource> SingleAsync<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, bool> predicate, string noneExceptionMessage, string manyExceptionMessage, bool disposeSource = true)
  • public static Task<TSource> SingleOrDefaultAsync<TSource>(this IAsyncEnumerator<TSource> source, bool disposeSource = true)
  • public static Task<TSource> SingleOrDefaultAsync<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, bool> predicate, bool disposeSource = true)
  • public static IAsyncEnumerator<TSource> Skip<TSource>(this IAsyncEnumerator<TSource> source, int count, bool disposeSource = true)
  • public static IAsyncEnumerator<TSource> SkipWhile<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, bool> predicate, bool disposeSource = true)
  • public static IAsyncEnumerator<TSource> Take<TSource>(this IAsyncEnumerator<TSource> source, int count, bool disposeSource = true)
  • public static IAsyncEnumerator<TSource> TakeWhile<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, bool> predicate, bool disposeSource = true)
  • public static Task<T[]> ToArrayAsync<T>(this IAsyncEnumerator<T> source, bool disposeSource = true)
  • public static Task<List<T>> ToListAsync<T>(this IAsyncEnumerator<T> source, bool disposeSource = true)
  • public static IAsyncEnumerator<T> UnionAll<T>(this IAsyncEnumerator<T> first, IAsyncEnumerator<T> second, bool disposeSource = true)
  • public static IAsyncEnumerator<T> UnionAll<T>(this IEnumerable<IAsyncEnumerator<T>> collections, bool disposeSource = true)
  • public static IAsyncEnumerator<TSource> Where<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, bool> predicate, bool disposeSource = true)
  • public static IAsyncEnumerator<TSource> Where<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, long, bool> predicate, bool disposeSource = true)
  • public static IAsyncEnumerator<List<TSource>> Batch<TSource>(this IAsyncEnumerator<TSource> source, int batchSize, bool disposeSource = true)
  • public static IAsyncEnumerator<TStandardCollection> Batch<TSource, TStandardCollection>(this IAsyncEnumerator<TSource> source, int batchSize, bool disposeSource = true)
  • public static IAsyncEnumerator<List<TSource>> Batch<TSource>(this IAsyncEnumerator<TSource> source, long maxBatchWeight, Func<TSource, long> weightSelector, bool disposeSource = true)
  • public static IAsyncEnumerator<TStandardCollection> Batch<TSource, TStandardCollection>(this IAsyncEnumerator<TSource> source, long maxBatchWeight, Func<TSource, long> weightSelector, bool disposeSource = true)
  • public static IAsyncEnumerator<List<TSource>> Batch<TSource>(this IAsyncEnumerator<TSource> source, int maxItemsInBatch, long maxBatchWeight, Func<TSource, long> weightSelector, bool disposeSource = true)
  • public static IAsyncEnumerator<TStandardCollection> Batch<TSource, TStandardCollection>(this IAsyncEnumerator<TSource> source, int maxItemsInBatch, long maxBatchWeight, Func<TSource, long> weightSelector, bool disposeSource = true)
  • public static IAsyncEnumerator<TBatch> Batch<TSource, TBatch>(this IAsyncEnumerator<TSource> source, int? maxItemsInBatch, long maxBatchWeight, Func<TSource, long> weightSelector, Func<int?, TBatch> createBatch, Action<TBatch, TSource> addItem, bool disposeSource = true)
  • public static IAsyncEnumerator<TResult> Cast<TResult>(this IAsyncEnumerator source, bool disposeSource = true)
  • public static IAsyncEnumerator<TSource> DefaultIfEmpty<TSource>(this IAsyncEnumerator<TSource> source, bool disposeSource = true)
  • public static IAsyncEnumerator<TSource> DefaultIfEmpty<TSource>(this IAsyncEnumerator<TSource> source, TSource defaultValue, bool disposeSource = true)
  • public static Task<TSource> FirstAsync<TSource>(this IAsyncEnumerator<TSource> source, bool disposeSource = true)
  • public static Task<TSource> FirstAsync<TSource>(this IAsyncEnumerator<TSource> source, string exceptionMessage, bool disposeSource = true)
  • public static Task<TSource> FirstAsync<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, bool> predicate, bool disposeSource = true)
  • public static Task<TSource> FirstAsync<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, bool> predicate, string exceptionMessage, bool disposeSource = true)
  • public static Task<TSource> FirstOrDefaultAsync<TSource>(this IAsyncEnumerator<TSource> source, bool disposeSource = true)
  • public static Task<TSource> FirstOrDefaultAsync<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, bool> predicate, bool disposeSource = true)
  • public static IAsyncEnumerator<TResult> Select<TSource, TResult>(this IAsyncEnumerator<TSource> source, Func<TSource, TResult> selector, bool disposeSource = true)
  • public static IAsyncEnumerator<TResult> Select<TSource, TResult>(this IAsyncEnumerator<TSource> source, Func<TSource, long, TResult> selector, bool disposeSource = true)
  • public static Task<TSource> SingleAsync<TSource>(this IAsyncEnumerator<TSource> source, bool disposeSource = true)
  • public static Task<TSource> SingleAsync<TSource>(this IAsyncEnumerator<TSource> source, string noneExceptionMessage, string manyExceptionMessage, bool disposeSource = true)
  • public static Task<TSource> SingleAsync<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, bool> predicate, bool disposeSource = true)
  • public static Task<TSource> SingleAsync<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, bool> predicate, string noneExceptionMessage, string manyExceptionMessage, bool disposeSource = true)
  • public static Task<TSource> SingleOrDefaultAsync<TSource>(this IAsyncEnumerator<TSource> source, bool disposeSource = true)
  • public static Task<TSource> SingleOrDefaultAsync<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, bool> predicate, bool disposeSource = true)
  • public static IAsyncEnumerator<TSource> Skip<TSource>(this IAsyncEnumerator<TSource> source, int count, bool disposeSource = true)
  • public static IAsyncEnumerator<TSource> SkipWhile<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, bool> predicate, bool disposeSource = true)
  • public static IAsyncEnumerator<TSource> Take<TSource>(this IAsyncEnumerator<TSource> source, int count, bool disposeSource = true)
  • public static IAsyncEnumerator<TSource> TakeWhile<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, bool> predicate, bool disposeSource = true)
  • public static Task<T[]> ToArrayAsync<T>(this IAsyncEnumerator<T> source, bool disposeSource = true)
  • public static Task<List<T>> ToListAsync<T>(this IAsyncEnumerator<T> source, bool disposeSource = true)
  • public static IAsyncEnumerator<T> UnionAll<T>(this IAsyncEnumerator<T> first, IAsyncEnumerator<T> second, bool disposeSource = true)
  • public static IAsyncEnumerator<T> UnionAll<T>(this IEnumerable<IAsyncEnumerator<T>> collections, bool disposeSource = true)
  • public static IAsyncEnumerator<TSource> Where<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, bool> predicate, bool disposeSource = true)
  • public static IAsyncEnumerator<TSource> Where<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, long, bool> predicate, bool disposeSource = true)
• public static class ParallelForEachExtensions
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, long, Task> asyncItemAction, int maxDegreeOfParallelism, bool breakLoopOnException, bool gracefulBreak, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, long, Task> asyncItemAction, int maxDegreeOfParallelism, bool breakLoopOnException, bool gracefulBreak, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, long, Task> asyncItemAction, int maxDegreeOfParallelism, bool breakLoopOnException, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, long, Task> asyncItemAction, int maxDegreeOfParallelism, bool breakLoopOnException, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, long, Task> asyncItemAction, int maxDegreeOfParallelism, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, long, Task> asyncItemAction, int maxDegreeOfParallelism, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, long, Task> asyncItemAction, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, long, Task> asyncItemAction, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, Task> asyncItemAction, int maxDegreeOfParallelism, bool breakLoopOnException, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, Task> asyncItemAction, int maxDegreeOfParallelism, bool breakLoopOnException, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, Task> asyncItemAction, int maxDegreeOfParallelism, bool breakLoopOnException, bool gracefulBreak, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, Task> asyncItemAction, int maxDegreeOfParallelism, bool breakLoopOnException, bool gracefulBreak, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, Task> asyncItemAction, int maxDegreeOfParallelism, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, Task> asyncItemAction, int maxDegreeOfParallelism, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, Task> asyncItemAction, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, Task> asyncItemAction, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, long, Task> asyncItemAction, int maxDegreeOfParallelism, bool breakLoopOnException, bool gracefulBreak, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, long, Task> asyncItemAction, int maxDegreeOfParallelism, bool breakLoopOnException, bool gracefulBreak, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, long, Task> asyncItemAction, int maxDegreeOfParallelism, bool breakLoopOnException, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, long, Task> asyncItemAction, int maxDegreeOfParallelism, bool breakLoopOnException, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, long, Task> asyncItemAction, int maxDegreeOfParallelism, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, long, Task> asyncItemAction, int maxDegreeOfParallelism, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, long, Task> asyncItemAction, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, long, Task> asyncItemAction, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, Task> asyncItemAction, int maxDegreeOfParallelism, bool breakLoopOnException, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, Task> asyncItemAction, int maxDegreeOfParallelism, bool breakLoopOnException, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, Task> asyncItemAction, int maxDegreeOfParallelism, bool breakLoopOnException, bool gracefulBreak, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, Task> asyncItemAction, int maxDegreeOfParallelism, bool breakLoopOnException, bool gracefulBreak, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, Task> asyncItemAction, int maxDegreeOfParallelism, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, Task> asyncItemAction, int maxDegreeOfParallelism, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, Task> asyncItemAction, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, Task> asyncItemAction, CancellationToken cancellationToken = default)