stevejgordon · October 14, 2020 08:39
diff --git a/UnboundedChannel.cs b/UnboundedChannel.cs
 public virtual async IAsyncEnumerable<T> ReadAllAsync([EnumeratorCancellation] CancellationToken cancellationToken = default)
 {
    while (await WaitToReadAsync(cancellationToken).ConfigureAwait(false))
    {
        while (TryRead(out T item))
        {
            yield return item;
        }
    }
 }
	public virtual async IAsyncEnumerable<T> ReadAllAsync([EnumeratorCancellation] CancellationToken cancellationToken = default)
	{
	while (await WaitToReadAsync(cancellationToken).ConfigureAwait(false))
	{
	while (TryRead(out T item))
	{
	yield return item;
	}
	}
	}