// Licensed to the .NET Foundation under one or more agreements. // The .NET Foundation licenses this file to you under the Apache 2.0 License. // See the LICENSE file in the project root for more information. using System.Collections.Generic; using System.Diagnostics; using System.Threading; using System.Threading.Tasks; namespace System.Linq { public static partial class AsyncEnumerable { public static IAsyncEnumerable CreateEnumerable(Func> getEnumerator) { if (getEnumerator == null) throw new ArgumentNullException(nameof(getEnumerator)); return new AnonymousAsyncEnumerable(_ => getEnumerator()); } public static IAsyncEnumerable CreateEnumerable(Func> getEnumerator) { if (getEnumerator == null) throw new ArgumentNullException(nameof(getEnumerator)); return new AnonymousAsyncEnumerable(getEnumerator); } public static IAsyncEnumerable CreateEnumerable(Func>> getEnumerator) { if (getEnumerator == null) throw new ArgumentNullException(nameof(getEnumerator)); return new AnonymousAsyncEnumerableWithTask(_ => getEnumerator()); } public static IAsyncEnumerable CreateEnumerable(Func>> getEnumerator) { if (getEnumerator == null) throw new ArgumentNullException(nameof(getEnumerator)); return new AnonymousAsyncEnumerableWithTask(getEnumerator); } public static IAsyncEnumerator CreateEnumerator(Func> moveNext, Func current, Func dispose) { return AsyncEnumerator.Create(moveNext, current, dispose); } private static IAsyncEnumerator CreateEnumerator(Func, ValueTask> moveNext, Func current, Func dispose) { return AsyncEnumerator.Create(moveNext, current, dispose); } private sealed class AnonymousAsyncEnumerable : IAsyncEnumerable { private readonly Func> _getEnumerator; public AnonymousAsyncEnumerable(Func> getEnumerator) { Debug.Assert(getEnumerator != null); _getEnumerator = getEnumerator; } public IAsyncEnumerator GetAsyncEnumerator(CancellationToken cancellationToken) => _getEnumerator(cancellationToken); } private sealed class AnonymousAsyncEnumerableWithTask : IAsyncEnumerable { private readonly Func>> _getEnumerator; public AnonymousAsyncEnumerableWithTask(Func>> getEnumerator) { Debug.Assert(getEnumerator != null); _getEnumerator = getEnumerator; } public IAsyncEnumerator GetAsyncEnumerator(CancellationToken cancellationToken) => new Enumerator(_getEnumerator, cancellationToken); private sealed class Enumerator : IAsyncEnumerator { private Func>> _getEnumerator; private readonly CancellationToken _cancellationToken; private IAsyncEnumerator _enumerator; public Enumerator(Func>> getEnumerator, CancellationToken cancellationToken) { Debug.Assert(getEnumerator != null); _getEnumerator = getEnumerator; _cancellationToken = cancellationToken; } public T Current { get { if (_enumerator == null) throw new InvalidOperationException(); return _enumerator.Current; } } public async ValueTask DisposeAsync() { var old = Interlocked.Exchange(ref _enumerator, DisposedEnumerator.Instance); if (_enumerator != null) { await _enumerator.DisposeAsync().ConfigureAwait(false); } } public ValueTask MoveNextAsync() { if (_enumerator == null) { return InitAndMoveNextAsync(); } return _enumerator.MoveNextAsync(); } private async ValueTask InitAndMoveNextAsync() { try { _enumerator = await _getEnumerator(_cancellationToken).ConfigureAwait(false); } catch (Exception ex) { _enumerator = Throw(ex).GetAsyncEnumerator(_cancellationToken); throw; } finally { _getEnumerator = null; } return await _enumerator.MoveNextAsync().ConfigureAwait(false); } private sealed class DisposedEnumerator : IAsyncEnumerator { public static readonly DisposedEnumerator Instance = new DisposedEnumerator(); public T Current => throw new ObjectDisposedException("this"); public ValueTask DisposeAsync() => TaskExt.CompletedTask; public ValueTask MoveNextAsync() => throw new ObjectDisposedException("this"); } } } } }