ReadAsync()

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

inlinevirtual

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

Definition at line 36 of file SingleConsumerUnboundedChannel.cs.

        {
            if (cancellationToken.IsCancellationRequested)
            {
                return new ValueTask<T>(Task.FromCanceled<T>(cancellationToken));
            }
            if (TryRead(out var item))
            {
                return new ValueTask<T>(item);
            }
            SingleConsumerUnboundedChannel<T> parent = _parent;
            AsyncOperation<T> asyncOperation;
            AsyncOperation<T> asyncOperation2;
            lock (parent.SyncObj)
            {
                if (TryRead(out item))
                {
                    return new ValueTask<T>(item);
                }
                if (parent._doneWriting != null)
                {
                    return ChannelUtilities.GetInvalidCompletionValueTask<T>(parent._doneWriting);
                }
                asyncOperation = parent._blockedReader;
                if (!cancellationToken.CanBeCanceled && _readerSingleton.TryOwnAndReset())
                {
                    asyncOperation2 = _readerSingleton;
                    if (asyncOperation2 == asyncOperation)
                    {
                        asyncOperation = null;
                    }
                }
                else
                {
                    asyncOperation2 = new AsyncOperation<T>(_parent._runContinuationsAsynchronously, cancellationToken);
                }
                parent._blockedReader = asyncOperation2;
            }
            asyncOperation?.TrySetCanceled();
            return asyncOperation2.ValueTaskOfT;
        }

References System.Threading.Channels.SingleConsumerUnboundedChannel< T >.UnboundedChannelReader._parent, System.Threading.Channels.SingleConsumerUnboundedChannel< T >.UnboundedChannelReader._readerSingleton, System.cancellationToken, System.Threading.Tasks.Task< TResult >.FromCanceled(), System.item, System.Threading.Channels.AsyncOperation< TResult >.TryOwnAndReset(), and System.Threading.Channels.SingleConsumerUnboundedChannel< T >.UnboundedChannelReader.TryRead().