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

---

API Differences between 2.0.1 and 4.0.1

135 Additions 24 Removals

Dasync.Collections

• public abstract class AsyncEnumerable : IAsyncEnumerable
• public class AsyncEnumerable<T> : AsyncEnumerable, IAsyncEnumerable, IAsyncEnumerable<T>
• public static class AsyncEnumerableAdapterExtensions
• public class AsyncEnumerableWithState<TItem, TState> : AsyncEnumerable, IAsyncEnumerable, IAsyncEnumerable<TItem>
• public sealed class AsyncEnumerationCanceledException : OperationCanceledException
• public abstract class AsyncEnumerator
• public class AsyncEnumerator<T> : AsyncEnumeratorWithState<T, NoStateAdapter<T>>
• public class AsyncEnumeratorWithState<TItem, TState> : CurrentValueContainer<TItem>, IAsyncEnumerator, IDisposable, IAsyncDisposable, IAsyncEnumerator<TItem>
• public static class EnumerableExtensions
• public static class ForEachAsync
• public sealed class ForEachAsyncBreakException : OperationCanceledException
• public static class ForEachAsyncExtensions
• public static class GenericEnumerableExtensions
• public interface IAsyncDisposable
• public interface IAsyncEnumerable
• public interface IAsyncEnumerable<T> : IAsyncEnumerable
• public static class IAsyncEnumerableExtensions
• public interface IAsyncEnumerator : IDisposable, IAsyncDisposable
• public interface IAsyncEnumerator<T> : IAsyncEnumerator, IDisposable, IAsyncDisposable
• public static class IAsyncEnumeratorExtensions
• public class ParallelForEachException : AggregateException
• public static class ParallelForEachExtensions

Dasync.Collections.Internals

• public abstract class CurrentValueContainer<T> : AsyncEnumerator
• public static class TaskCompletionSource

System.Collections

• public static class IEnumerableExtensions
  • public static IAsyncEnumerable ToAsyncEnumerable(this IEnumerable enumerable, bool runSynchronously = true)

System.Collections.Async

• public abstract class AsyncEnumerable : IAsyncEnumerable
  • protected AsyncEnumerable()
  • public static IAsyncEnumerable<T> Empty<T>()
• public class AsyncEnumerable<T> : AsyncEnumerable, IAsyncEnumerable<T>, IAsyncEnumerable
  • public static readonly IAsyncEnumerable<T> Empty
  • public AsyncEnumerable(Func<Yield<T>, Task> enumerationFunction)
  • public virtual Task<IAsyncEnumerator<T>> GetAsyncEnumeratorAsync(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 class AsyncEnumerableWithState<TItem, TState> : AsyncEnumerable, IAsyncEnumerable<TItem>, IAsyncEnumerable
  • protected TState State { get; }
  • public AsyncEnumerableWithState(Func<Yield<TItem>, TState, Task> enumerationFunction, TState state)
  • public virtual Task<IAsyncEnumerator<TItem>> GetAsyncEnumeratorAsync(CancellationToken cancellationToken = default)
• public sealed class AsyncEnumerationCanceledException : OperationCanceledException
  • public AsyncEnumerationCanceledException()
• public abstract class AsyncEnumerator
  • protected AsyncEnumerator()
  • public static IAsyncEnumerator<T> Empty<T>()
• public class AsyncEnumerator<T> : AsyncEnumeratorWithState<T, NoStateAdapter<T>>
  • public struct NoStateAdapter<T>
  • public sealed class Yield<T>
  • public static readonly IAsyncEnumerator<T> Empty
  • public AsyncEnumerator(Func<Yield<T>, Task> enumerationFunction, Action onDispose = null)
• public class AsyncEnumeratorWithState<TItem, TState> : CurrentValueContainer<TItem>, IAsyncEnumerator<TItem>, IAsyncEnumerator, IDisposable
  • public virtual TItem Current { get; }
  • public bool IsEnumerationComplete { get; }
  • protected TState State { get; }
  • public AsyncEnumeratorWithState(Func<Yield<TItem>, TState, Task> enumerationFunction, TState state, Action<TState> onDispose = null)
  • public void Dispose()
  • protected virtual void Dispose(bool manualDispose)
  • public virtual Task<bool> MoveNextAsync(CancellationToken cancellationToken = default)
• 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, CancellationToken cancellationToken = default)
  • 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, CancellationToken cancellationToken = default)
  • 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, CancellationToken cancellationToken = default)
  • 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, CancellationToken cancellationToken = default)
  • 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, CancellationToken cancellationToken = default)
  • 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, CancellationToken cancellationToken = default)
  • 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, CancellationToken cancellationToken = default)
  • 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, CancellationToken cancellationToken = default)
• public interface IAsyncEnumerable
  • Task<IAsyncEnumerator> GetAsyncEnumeratorAsync(CancellationToken cancellationToken = default)
• public interface IAsyncEnumerable<T> : IAsyncEnumerable
  • Task<IAsyncEnumerator<T>> GetAsyncEnumeratorAsync(CancellationToken cancellationToken = default)
• public static class IAsyncEnumerableExtensions
  • public static Task<TSource> FirstAsync<TSource>(this IAsyncEnumerable<TSource> source, CancellationToken token = default)
  • public static Task<TSource> FirstAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, bool> predicate, 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> 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<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<List<T>> ToListAsync<T>(this IAsyncEnumerable<T> source, CancellationToken cancellationToken = default)
  • 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 : IDisposable
  • object Current { get; }
  • Task<bool> MoveNextAsync(CancellationToken cancellationToken = default)
• public interface IAsyncEnumerator<T> : IAsyncEnumerator, IDisposable
  • T Current { get; }
• public static class IAsyncEnumeratorExtensions
  • public static Task<TSource> FirstAsync<TSource>(this IAsyncEnumerator<TSource> source, CancellationToken token = default, bool disposeSource = true)
  • public static Task<TSource> FirstAsync<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, bool> predicate, CancellationToken token = default, bool disposeSource = true)
  • public static Task<TSource> FirstOrDefaultAsync<TSource>(this IAsyncEnumerator<TSource> source, CancellationToken token = default, bool disposeSource = true)
  • public static Task<TSource> FirstOrDefaultAsync<TSource>(this IAsyncEnumerator<TSource> source, Func<TSource, bool> predicate, CancellationToken token = default, 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 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, CancellationToken cancellationToken = default, bool disposeSource = true)
  • public static Task<List<T>> ToListAsync<T>(this IAsyncEnumerator<T> source, CancellationToken cancellationToken = default, 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 class ParallelForEachException : AggregateException
  • public ParallelForEachException(IEnumerable<Exception> innerExceptions)
• public static class ParallelForEachExtensions
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, long, Task> asyncItemAction, int maxDegreeOfParalellism, bool breakLoopOnException, bool gracefulBreak, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, long, Task> asyncItemAction, int maxDegreeOfParalellism, bool breakLoopOnException, bool gracefulBreak, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, long, Task> asyncItemAction, int maxDegreeOfParalellism, bool breakLoopOnException, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, long, Task> asyncItemAction, int maxDegreeOfParalellism, bool breakLoopOnException, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, long, Task> asyncItemAction, int maxDegreeOfParalellism, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, long, Task> asyncItemAction, int maxDegreeOfParalellism, 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 maxDegreeOfParalellism, bool breakLoopOnException, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, Task> asyncItemAction, int maxDegreeOfParalellism, bool breakLoopOnException, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, Task> asyncItemAction, int maxDegreeOfParalellism, bool breakLoopOnException, bool gracefulBreak, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, Task> asyncItemAction, int maxDegreeOfParalellism, bool breakLoopOnException, bool gracefulBreak, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerable<T> collection, Func<T, Task> asyncItemAction, int maxDegreeOfParalellism, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IAsyncEnumerator<T> enumerator, Func<T, Task> asyncItemAction, int maxDegreeOfParalellism, 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 IEnumerable<T> collection, Func<T, long, Task> asyncItemAction, int maxDegreeOfParalellism, bool breakLoopOnException, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IEnumerator<T> enumerator, Func<T, long, Task> asyncItemAction, int maxDegreeOfParalellism, bool breakLoopOnException, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IEnumerable<T> collection, Func<T, long, Task> asyncItemAction, int maxDegreeOfParalellism, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IEnumerator<T> enumerator, Func<T, long, Task> asyncItemAction, int maxDegreeOfParalellism, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IEnumerable<T> collection, Func<T, long, Task> asyncItemAction, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IEnumerator<T> enumerator, Func<T, long, Task> asyncItemAction, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IEnumerable<T> collection, Func<T, Task> asyncItemAction, int maxDegreeOfParalellism, bool breakLoopOnException, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IEnumerator<T> enumerator, Func<T, Task> asyncItemAction, int maxDegreeOfParalellism, bool breakLoopOnException, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IEnumerable<T> collection, Func<T, Task> asyncItemAction, int maxDegreeOfParalellism, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IEnumerator<T> enumerator, Func<T, Task> asyncItemAction, int maxDegreeOfParalellism, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IEnumerable<T> collection, Func<T, Task> asyncItemAction, CancellationToken cancellationToken = default)
  • public static Task ParallelForEachAsync<T>(this IEnumerator<T> enumerator, Func<T, Task> asyncItemAction, CancellationToken cancellationToken = default)

System.Collections.Async.Internals

• public abstract class CurrentValueContainer<T> : AsyncEnumerator
  • protected CurrentValueContainer()
• public static class TaskCompletionSource
  • public static void DisableTaskCompletionSourceReUse()
  • public static void Reset<T>(ref TaskCompletionSource taskCompletionSource, object stateObject = null)

System.Collections.Generic

• public static class IEnumerableExtensions
  • 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)