// 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.Tasks; namespace System.Linq { public static partial class AsyncEnumerable { public static IAsyncEnumerable TakeWhile(this IAsyncEnumerable source, Func predicate) { if (source == null) throw new ArgumentNullException(nameof(source)); if (predicate == null) throw new ArgumentNullException(nameof(predicate)); return new TakeWhileAsyncIterator(source, predicate); } public static IAsyncEnumerable TakeWhile(this IAsyncEnumerable source, Func predicate) { if (source == null) throw new ArgumentNullException(nameof(source)); if (predicate == null) throw new ArgumentNullException(nameof(predicate)); return new TakeWhileWithIndexAsyncIterator(source, predicate); } public static IAsyncEnumerable TakeWhile(this IAsyncEnumerable source, Func> predicate) { if (source == null) throw new ArgumentNullException(nameof(source)); if (predicate == null) throw new ArgumentNullException(nameof(predicate)); return new TakeWhileAsyncIteratorWithTask(source, predicate); } public static IAsyncEnumerable TakeWhile(this IAsyncEnumerable source, Func> predicate) { if (source == null) throw new ArgumentNullException(nameof(source)); if (predicate == null) throw new ArgumentNullException(nameof(predicate)); return new TakeWhileWithIndexAsyncIteratorWithTask(source, predicate); } private sealed class TakeWhileAsyncIterator : AsyncIterator { private readonly Func predicate; private readonly IAsyncEnumerable source; private IAsyncEnumerator enumerator; public TakeWhileAsyncIterator(IAsyncEnumerable source, Func predicate) { Debug.Assert(predicate != null); Debug.Assert(source != null); this.source = source; this.predicate = predicate; } public override AsyncIterator Clone() { return new TakeWhileAsyncIterator(source, predicate); } public override async Task DisposeAsync() { if (enumerator != null) { await enumerator.DisposeAsync().ConfigureAwait(false); enumerator = null; } await base.DisposeAsync().ConfigureAwait(false); } protected override async Task MoveNextCore() { switch (state) { case AsyncIteratorState.Allocated: enumerator = source.GetAsyncEnumerator(); state = AsyncIteratorState.Iterating; goto case AsyncIteratorState.Iterating; case AsyncIteratorState.Iterating: if (await enumerator.MoveNextAsync().ConfigureAwait(false)) { var item = enumerator.Current; if (!predicate(item)) { break; } current = item; return true; } break; } await DisposeAsync().ConfigureAwait(false); return false; } } private sealed class TakeWhileWithIndexAsyncIterator : AsyncIterator { private readonly Func predicate; private readonly IAsyncEnumerable source; private IAsyncEnumerator enumerator; private int index; public TakeWhileWithIndexAsyncIterator(IAsyncEnumerable source, Func predicate) { Debug.Assert(predicate != null); Debug.Assert(source != null); this.source = source; this.predicate = predicate; } public override AsyncIterator Clone() { return new TakeWhileWithIndexAsyncIterator(source, predicate); } public override async Task DisposeAsync() { if (enumerator != null) { await enumerator.DisposeAsync().ConfigureAwait(false); enumerator = null; } await base.DisposeAsync().ConfigureAwait(false); } protected override async Task MoveNextCore() { switch (state) { case AsyncIteratorState.Allocated: enumerator = source.GetAsyncEnumerator(); index = -1; state = AsyncIteratorState.Iterating; goto case AsyncIteratorState.Iterating; case AsyncIteratorState.Iterating: if (await enumerator.MoveNextAsync().ConfigureAwait(false)) { var item = enumerator.Current; checked { index++; } if (!predicate(item, index)) { break; } current = item; return true; } break; } await DisposeAsync().ConfigureAwait(false); return false; } } private sealed class TakeWhileAsyncIteratorWithTask : AsyncIterator { private readonly Func> predicate; private readonly IAsyncEnumerable source; private IAsyncEnumerator enumerator; public TakeWhileAsyncIteratorWithTask(IAsyncEnumerable source, Func> predicate) { Debug.Assert(predicate != null); Debug.Assert(source != null); this.source = source; this.predicate = predicate; } public override AsyncIterator Clone() { return new TakeWhileAsyncIteratorWithTask(source, predicate); } public override async Task DisposeAsync() { if (enumerator != null) { await enumerator.DisposeAsync().ConfigureAwait(false); enumerator = null; } await base.DisposeAsync().ConfigureAwait(false); } protected override async Task MoveNextCore() { switch (state) { case AsyncIteratorState.Allocated: enumerator = source.GetAsyncEnumerator(); state = AsyncIteratorState.Iterating; goto case AsyncIteratorState.Iterating; case AsyncIteratorState.Iterating: if (await enumerator.MoveNextAsync().ConfigureAwait(false)) { var item = enumerator.Current; if (!await predicate(item).ConfigureAwait(false)) { break; } current = item; return true; } break; } await DisposeAsync().ConfigureAwait(false); return false; } } private sealed class TakeWhileWithIndexAsyncIteratorWithTask : AsyncIterator { private readonly Func> predicate; private readonly IAsyncEnumerable source; private IAsyncEnumerator enumerator; private int index; public TakeWhileWithIndexAsyncIteratorWithTask(IAsyncEnumerable source, Func> predicate) { Debug.Assert(predicate != null); Debug.Assert(source != null); this.source = source; this.predicate = predicate; } public override AsyncIterator Clone() { return new TakeWhileWithIndexAsyncIteratorWithTask(source, predicate); } public override async Task DisposeAsync() { if (enumerator != null) { await enumerator.DisposeAsync().ConfigureAwait(false); enumerator = null; } await base.DisposeAsync().ConfigureAwait(false); } protected override async Task MoveNextCore() { switch (state) { case AsyncIteratorState.Allocated: enumerator = source.GetAsyncEnumerator(); index = -1; state = AsyncIteratorState.Iterating; goto case AsyncIteratorState.Iterating; case AsyncIteratorState.Iterating: if (await enumerator.MoveNextAsync().ConfigureAwait(false)) { var item = enumerator.Current; checked { index++; } if (!await predicate(item, index).ConfigureAwait(false)) { break; } current = item; return true; } break; } await DisposeAsync().ConfigureAwait(false); return false; } } } }