ReadAsync()

virtual ValueTask< T > System.Threading.Channels.ChannelReader< T >.ReadAsync ( CancellationToken cancellationToken = default(CancellationToken) )

inlinevirtual

Reimplemented in System.Threading.Channels.BoundedChannel< T >.BoundedChannelReader, System.Threading.Channels.SingleConsumerUnboundedChannel< T >.UnboundedChannelReader, and System.Threading.Channels.UnboundedChannel< T >.UnboundedChannelReader.

Definition at line 34 of file ChannelReader.cs.

    {
        if (cancellationToken.IsCancellationRequested)
        {
            return new ValueTask<T>(Task.FromCanceled<T>(cancellationToken));
        }
        try
        {
            if (TryRead(out var item))
            {
                return new ValueTask<T>(item);
            }
        }
        catch (Exception ex) when (!(ex is ChannelClosedException) && !(ex is OperationCanceledException))
        {
            return new ValueTask<T>(Task.FromException<T>(ex));
        }
        return ReadAsyncCore(cancellationToken);
        async ValueTask<T> ReadAsyncCore(CancellationToken ct)
        {
            T item2;
            do
            {
                if (!(await WaitToReadAsync(ct).ConfigureAwait(continueOnCapturedContext: false)))
                {
                    throw new ChannelClosedException();
                }
            }
            while (!TryRead(out item2));
            return item2;
        }
    }

References System.cancellationToken, System.Threading.Tasks.Task< TResult >.FromCanceled(), System.Threading.Tasks.Task< TResult >.FromException(), System.item, System.Threading.Channels.ChannelReader< T >.TryRead(), and System.Threading.Channels.ChannelReader< T >.WaitToReadAsync().