// 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 AsyncEnumerableEx { public static IAsyncEnumerable Using(Func resourceFactory, Func> enumerableFactory) where TResource : IDisposable { if (resourceFactory == null) throw new ArgumentNullException(nameof(resourceFactory)); if (enumerableFactory == null) throw new ArgumentNullException(nameof(enumerableFactory)); return new UsingAsyncIterator(resourceFactory, enumerableFactory); } public static IAsyncEnumerable Using(Func> resourceFactory, Func>> enumerableFactory) where TResource : IDisposable { if (resourceFactory == null) throw new ArgumentNullException(nameof(resourceFactory)); if (enumerableFactory == null) throw new ArgumentNullException(nameof(enumerableFactory)); return new UsingAsyncIteratorWithTask(resourceFactory, enumerableFactory); } private sealed class UsingAsyncIterator : AsyncIterator where TResource : IDisposable { private readonly Func> enumerableFactory; private readonly Func resourceFactory; private IAsyncEnumerable enumerable; private IAsyncEnumerator enumerator; private TResource resource; public UsingAsyncIterator(Func resourceFactory, Func> enumerableFactory) { Debug.Assert(resourceFactory != null); Debug.Assert(enumerableFactory != null); this.resourceFactory = resourceFactory; this.enumerableFactory = enumerableFactory; } public override AsyncIterator Clone() { return new UsingAsyncIterator(resourceFactory, enumerableFactory); } public override async ValueTask DisposeAsync() { if (enumerator != null) { await enumerator.DisposeAsync().ConfigureAwait(false); enumerator = null; } if (resource != null) { resource.Dispose(); resource = default; } await base.DisposeAsync().ConfigureAwait(false); } protected override async ValueTask MoveNextCore(CancellationToken cancellationToken) { switch (state) { case AsyncIteratorState.Allocated: enumerator = enumerable.GetAsyncEnumerator(cancellationToken); state = AsyncIteratorState.Iterating; goto case AsyncIteratorState.Iterating; case AsyncIteratorState.Iterating: while (await enumerator.MoveNextAsync().ConfigureAwait(false)) { current = enumerator.Current; return true; } await DisposeAsync().ConfigureAwait(false); break; } return false; } protected override void OnGetEnumerator(CancellationToken cancellationToken) { // REVIEW: Wire cancellation to the functions. resource = resourceFactory(); enumerable = enumerableFactory(resource); base.OnGetEnumerator(cancellationToken); } } private sealed class UsingAsyncIteratorWithTask : AsyncIterator where TResource : IDisposable { private readonly Func>> enumerableFactory; private readonly Func> resourceFactory; private IAsyncEnumerable enumerable; private IAsyncEnumerator enumerator; private TResource resource; public UsingAsyncIteratorWithTask(Func> resourceFactory, Func>> enumerableFactory) { Debug.Assert(resourceFactory != null); Debug.Assert(enumerableFactory != null); this.resourceFactory = resourceFactory; this.enumerableFactory = enumerableFactory; } public override AsyncIterator Clone() { return new UsingAsyncIteratorWithTask(resourceFactory, enumerableFactory); } public override async ValueTask DisposeAsync() { if (enumerator != null) { await enumerator.DisposeAsync().ConfigureAwait(false); enumerator = null; } if (resource != null) { resource.Dispose(); resource = default; } await base.DisposeAsync().ConfigureAwait(false); } protected override async ValueTask MoveNextCore(CancellationToken cancellationToken) { switch (state) { case AsyncIteratorState.Allocated: resource = await resourceFactory().ConfigureAwait(false); enumerable = await enumerableFactory(resource).ConfigureAwait(false); enumerator = enumerable.GetAsyncEnumerator(cancellationToken); state = AsyncIteratorState.Iterating; goto case AsyncIteratorState.Iterating; case AsyncIteratorState.Iterating: while (await enumerator.MoveNextAsync().ConfigureAwait(false)) { current = enumerator.Current; return true; } await DisposeAsync().ConfigureAwait(false); break; } return false; } } } }