TryWrite()

override bool System.Threading.Channels.SingleConsumerUnboundedChannel< T >.UnboundedChannelWriter.TryWrite ( T item )

inline

Definition at line 209 of file SingleConsumerUnboundedChannel.cs.

        {
            SingleConsumerUnboundedChannel<T> parent = _parent;
            AsyncOperation<T> asyncOperation;
            do
            {
                asyncOperation = null;
                AsyncOperation<bool> asyncOperation2 = null;
                lock (parent.SyncObj)
                {
                    if (parent._doneWriting != null)
                    {
                        return false;
                    }
                    asyncOperation = parent._blockedReader;
                    if (asyncOperation != null)
                    {
                        parent._blockedReader = null;
                    }
                    else
                    {
                        parent._items.Enqueue(item);
                        asyncOperation2 = parent._waitingReader;
                        if (asyncOperation2 == null)
                        {
                            return true;
                        }
                        parent._waitingReader = null;
                    }
                }
                if (asyncOperation2 != null)
                {
                    asyncOperation2.TrySetResult(item: true);
                    return true;
                }
            }
            while (!asyncOperation.TrySetResult(item));
            return true;
        }

References System.Threading.Channels.SingleConsumerUnboundedChannel< T >.UnboundedChannelWriter._parent, and System.item.

Referenced by System.Threading.Channels.SingleConsumerUnboundedChannel< T >.UnboundedChannelWriter.WriteAsync().