Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ internal static class EnumerableExtensions
/// Converts an enumerable sequence to an async-enumerable sequence.
/// </summary>
/// <typeparam name="T">The type of the elements in the source sequence.</typeparam>
/// <param name="source">Th enumerable sequence to convert to an async-enumerable sequence.</param>
/// <param name="source">The enumerable sequence to convert to an async-enumerable sequence.</param>
/// <returns>
/// The async-enumerable sequence whose elements are pulled from the given enumerable sequence.
/// </returns>
Expand Down Expand Up @@ -48,8 +48,8 @@ private sealed class AsyncEnumeratorAdapter<T>(IEnumerator<T> enumerator, Cancel
/// <inheritdoc />
public ValueTask<bool> MoveNextAsync()
{
var result = !cancellationToken.IsCancellationRequested && enumerator.MoveNext();
return new ValueTask<bool>(result);
cancellationToken.ThrowIfCancellationRequested();
return new ValueTask<bool>(enumerator.MoveNext());
}

/// <inheritdoc />
Expand Down
Loading