// 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; using System.Collections.Generic; using System.Diagnostics; using System.Linq; using System.Threading; using System.Threading.Tasks; namespace System.Linq { public static partial class AsyncEnumerable { public static IAsyncEnumerable Select(this IAsyncEnumerable source, Func selector) { if (source == null) throw new ArgumentNullException(nameof(source)); if (selector == null) throw new ArgumentNullException(nameof(selector)); var iterator = source as AsyncIterator; if (iterator != null) { return iterator.Select(selector); } var ilist = source as IList; if (ilist != null) { return new SelectIListIterator(ilist, selector); } return new SelectEnumerableAsyncIterator(source, selector); } public static IAsyncEnumerable Select(this IAsyncEnumerable source, Func selector) { if (source == null) throw new ArgumentNullException(nameof(source)); if (selector == null) throw new ArgumentNullException(nameof(selector)); return CreateEnumerable( () => { var e = source.GetEnumerator(); var current = default(TResult); var index = 0; var cts = new CancellationTokenDisposable(); var d = Disposable.Create(cts, e); return CreateEnumerator( async ct => { if (await e.MoveNext(cts.Token) .ConfigureAwait(false)) { current = selector(e.Current, checked(index++)); return true; } return false; }, () => current, d.Dispose, e ); }); } private static Func CombineSelectors(Func selector1, Func selector2) { return x => selector2(selector1(x)); } internal sealed class SelectEnumerableAsyncIterator : AsyncIterator { private readonly IAsyncEnumerable source; private readonly Func selector; private IAsyncEnumerator enumerator; public SelectEnumerableAsyncIterator(IAsyncEnumerable source, Func selector) { Debug.Assert(source != null); Debug.Assert(selector != null); this.source = source; this.selector = selector; } public override AsyncIterator Clone() { return new SelectEnumerableAsyncIterator(source, selector); } public override void Dispose() { if (enumerator != null) { enumerator.Dispose(); enumerator = null; } base.Dispose(); } protected override async Task MoveNextCore(CancellationToken cancellationToken) { switch (state) { case AsyncIteratorState.Allocated: enumerator = source.GetEnumerator(); state = AsyncIteratorState.Iterating; goto case AsyncIteratorState.Iterating; case AsyncIteratorState.Iterating: if (await enumerator.MoveNext(cancellationToken) .ConfigureAwait(false)) { current = selector(enumerator.Current); return true; } Dispose(); break; } return false; } public override IAsyncEnumerable Select(Func selector) { return new SelectEnumerableAsyncIterator(source, CombineSelectors(this.selector, selector)); } } internal sealed class SelectIListIterator : AsyncIterator { private readonly IList source; private readonly Func selector; private IEnumerator enumerator; public SelectIListIterator(IList source, Func selector) { Debug.Assert(source != null); Debug.Assert(selector != null); this.source = source; this.selector = selector; } public override AsyncIterator Clone() { return new SelectIListIterator(source, selector); } public override void Dispose() { if (enumerator != null) { enumerator.Dispose(); enumerator = null; } base.Dispose(); } protected override Task MoveNextCore(CancellationToken cancellationToken) { switch (state) { case AsyncIteratorState.Allocated: enumerator = source.GetEnumerator(); state = AsyncIteratorState.Iterating; goto case AsyncIteratorState.Iterating; case AsyncIteratorState.Iterating: if ( enumerator.MoveNext()) { current = selector(enumerator.Current); return Task.FromResult(true); } Dispose(); break; } return Task.FromResult(false); } public override IAsyncEnumerable Select(Func selector) { return new SelectIListIterator(source, CombineSelectors(this.selector, selector)); } } } }