ReadAsync()

override ValueTask< T > System.Threading.Channels.UnboundedChannel< T >.UnboundedChannelReader.ReadAsync ( CancellationToken cancellationToken )

inlinevirtual

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

Definition at line 38 of file UnboundedChannel.cs.

        {
            if (cancellationToken.IsCancellationRequested)
            {
                return new ValueTask<T>(Task.FromCanceled<T>(cancellationToken));
            }
            UnboundedChannel<T> parent = _parent;
            if (parent._items.TryDequeue(out var result))
            {
                CompleteIfDone(parent);
                return new ValueTask<T>(result);
            }
            lock (parent.SyncObj)
            {
                if (parent._items.TryDequeue(out result))
                {
                    CompleteIfDone(parent);
                    return new ValueTask<T>(result);
                }
                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);
                parent._blockedReaders.EnqueueTail(asyncOperation);
                return asyncOperation.ValueTaskOfT;
            }
        }

References System.Threading.Channels.UnboundedChannel< T >.UnboundedChannelReader._parent, System.Threading.Channels.UnboundedChannel< T >.UnboundedChannelReader._readerSingleton, System.cancellationToken, System.Threading.Channels.UnboundedChannel< T >.UnboundedChannelReader.CompleteIfDone(), and System.Threading.Tasks.Task< TResult >.FromCanceled().