TryComplete() [1/2]

override bool System.Threading.Channels.SingleConsumerUnboundedChannel< T >.UnboundedChannelWriter.TryComplete ( Exception error )

inline

Definition at line 158 of file SingleConsumerUnboundedChannel.cs.

        {
            AsyncOperation<T> asyncOperation = null;
            AsyncOperation<bool> asyncOperation2 = null;
            bool flag = false;
            SingleConsumerUnboundedChannel<T> parent = _parent;
            lock (parent.SyncObj)
            {
                if (parent._doneWriting != null)
                {
                    return false;
                }
                parent._doneWriting = error ?? ChannelUtilities.s_doneWritingSentinel;
                if (parent._items.IsEmpty)
                {
                    flag = true;
                    if (parent._blockedReader != null)
                    {
                        asyncOperation = parent._blockedReader;
                        parent._blockedReader = null;
                    }
                    if (parent._waitingReader != null)
                    {
                        asyncOperation2 = parent._waitingReader;
                        parent._waitingReader = null;
                    }
                }
            }
            if (flag)
            {
                ChannelUtilities.Complete(parent._completion, error);
            }
            if (asyncOperation != null)
            {
                error = ChannelUtilities.CreateInvalidCompletionException(error);
                asyncOperation.TrySetException(error);
            }
            if (asyncOperation2 != null)
            {
                if (error != null)
                {
                    asyncOperation2.TrySetException(error);
                }
                else
                {
                    asyncOperation2.TrySetResult(item: false);
                }
            }
            return true;
        }

References System.Threading.Channels.SingleConsumerUnboundedChannel< T >.UnboundedChannelWriter._parent, System.Threading.Channels.ChannelUtilities.Complete(), System.Threading.Channels.ChannelUtilities.CreateInvalidCompletionException(), System.item, and System.Threading.Channels.ChannelUtilities.s_doneWritingSentinel.