ReadAsync()

override ValueTask< T > System.Threading.Channels.BoundedChannel< T >.BoundedChannelReader.ReadAsync ( CancellationToken cancellationToken )

inlinevirtual

Reimplemented from System.Threading.Channels.ChannelReader< T >.

Definition at line 79 of file BoundedChannel.cs.

        {
            if (cancellationToken.IsCancellationRequested)
            {
                return new ValueTask<T>(Task.FromCanceled<T>(cancellationToken));
            }
            BoundedChannel<T> parent = _parent;
            lock (parent.SyncObj)
            {
                if (!parent._items.IsEmpty)
                {
                    return new ValueTask<T>(DequeueItemAndPostProcess());
                }
                if (parent._doneWriting != null)
                {
                    return ChannelUtilities.GetInvalidCompletionValueTask<T>(parent._doneWriting);
                }
                if (!cancellationToken.CanBeCanceled)
                {
                    AsyncOperation<T> readerSingleton = _readerSingleton;
                    if (readerSingleton.TryOwnAndReset())
                    {
                        parent._blockedReaders.EnqueueTail(readerSingleton);
                        return readerSingleton.ValueTaskOfT;
                    }
                }
                AsyncOperation<T> asyncOperation = new AsyncOperation<T>(parent._runContinuationsAsynchronously | cancellationToken.CanBeCanceled, cancellationToken);
                parent._blockedReaders.EnqueueTail(asyncOperation);
                return asyncOperation.ValueTaskOfT;
            }
        }

References System.Threading.Channels.BoundedChannel< T >.BoundedChannelReader._parent, System.Threading.Channels.BoundedChannel< T >.BoundedChannelReader._readerSingleton, System.cancellationToken, System.Threading.Channels.BoundedChannel< T >.BoundedChannelReader.DequeueItemAndPostProcess(), and System.Threading.Tasks.Task< TResult >.FromCanceled().