WaitToReadAsync()

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

inline

Definition at line 97 of file SingleConsumerUnboundedChannel.cs.

        {
            if (cancellationToken.IsCancellationRequested)
            {
                return new ValueTask<bool>(Task.FromCanceled<bool>(cancellationToken));
            }
            if (!_parent._items.IsEmpty)
            {
                return new ValueTask<bool>(result: true);
            }
            SingleConsumerUnboundedChannel<T> parent = _parent;
            AsyncOperation<bool> asyncOperation = null;
            AsyncOperation<bool> asyncOperation2;
            lock (parent.SyncObj)
            {
                if (!parent._items.IsEmpty)
                {
                    return new ValueTask<bool>(result: true);
                }
                if (parent._doneWriting != null)
                {
                    return (parent._doneWriting != ChannelUtilities.s_doneWritingSentinel) ? new ValueTask<bool>(Task.FromException<bool>(parent._doneWriting)) : default(ValueTask<bool>);
                }
                asyncOperation = parent._waitingReader;
                if (!cancellationToken.CanBeCanceled && _waiterSingleton.TryOwnAndReset())
                {
                    asyncOperation2 = _waiterSingleton;
                    if (asyncOperation2 == asyncOperation)
                    {
                        asyncOperation = null;
                    }
                }
                else
                {
                    asyncOperation2 = new AsyncOperation<bool>(_parent._runContinuationsAsynchronously, cancellationToken);
                }
                parent._waitingReader = asyncOperation2;
            }
            asyncOperation?.TrySetCanceled();
            return asyncOperation2.ValueTaskOfT;
        }

References System.Threading.Channels.SingleConsumerUnboundedChannel< T >.UnboundedChannelReader._parent, System.Threading.Channels.SingleConsumerUnboundedChannel< T >.UnboundedChannelReader._waiterSingleton, System.cancellationToken, System.Threading.Tasks.Task< TResult >.FromCanceled(), System.Threading.Tasks.Task< TResult >.FromException(), System.Threading.Channels.ChannelUtilities.s_doneWritingSentinel, and System.Threading.Channels.AsyncOperation< TResult >.TryOwnAndReset().