WaitToWriteAsync()

override ValueTask< bool > System.Threading.Channels.BoundedChannel< T >.BoundedChannelWriter.WaitToWriteAsync ( CancellationToken cancellationToken )

inline

Definition at line 298 of file BoundedChannel.cs.

        {
            if (cancellationToken.IsCancellationRequested)
            {
                return new ValueTask<bool>(Task.FromCanceled<bool>(cancellationToken));
            }
            BoundedChannel<T> parent = _parent;
            lock (parent.SyncObj)
            {
                if (parent._doneWriting != null)
                {
                    return (parent._doneWriting != ChannelUtilities.s_doneWritingSentinel) ? new ValueTask<bool>(Task.FromException<bool>(parent._doneWriting)) : default(ValueTask<bool>);
                }
                if (parent._items.Count < parent._bufferedCapacity || parent._mode != 0)
                {
                    return new ValueTask<bool>(result: true);
                }
                if (!cancellationToken.CanBeCanceled)
                {
                    AsyncOperation<bool> waiterSingleton = _waiterSingleton;
                    if (waiterSingleton.TryOwnAndReset())
                    {
                        ChannelUtilities.QueueWaiter(ref parent._waitingWritersTail, waiterSingleton);
                        return waiterSingleton.ValueTaskOfT;
                    }
                }
                AsyncOperation<bool> asyncOperation = new AsyncOperation<bool>(runContinuationsAsynchronously: true, cancellationToken);
                ChannelUtilities.QueueWaiter(ref parent._waitingWritersTail, asyncOperation);
                return asyncOperation.ValueTaskOfT;
            }
        }

References System.Threading.Channels.BoundedChannel< T >.BoundedChannelWriter._parent, System.Threading.Channels.BoundedChannel< T >.BoundedChannelWriter._waiterSingleton, System.cancellationToken, System.Collections.Generic.Dictionary< TKey, TValue >.Count, System.Threading.Tasks.Task< TResult >.FromCanceled(), System.Threading.Tasks.Task< TResult >.FromException(), System.Threading.Channels.ChannelUtilities.QueueWaiter(), and System.Threading.Channels.ChannelUtilities.s_doneWritingSentinel.