1 write to _doneWriting
System.Threading.Channels (1)
System\Threading\Channels\UnboundedPriorityChannel.cs (1)
222
parent.
_doneWriting
= error ?? ChannelUtilities.s_doneWritingSentinel;
13 references to _doneWriting
System.Threading.Channels (13)
System\Threading\Channels\UnboundedPriorityChannel.cs (13)
90
if (parent.
_doneWriting
!= null)
92
return ChannelUtilities.GetInvalidCompletionValueTask<T>(parent.
_doneWriting
);
143
if (parent.
_doneWriting
!= null && parent._items.Count == 0)
146
ChannelUtilities.Complete(parent._completion, parent.
_doneWriting
);
169
if (parent.
_doneWriting
!= null)
171
return parent.
_doneWriting
!= ChannelUtilities.s_doneWritingSentinel ?
172
ValueTask.FromException<bool>(parent.
_doneWriting
) :
216
if (parent.
_doneWriting
!= null)
257
if (parent.
_doneWriting
!= null)
308
Exception? doneWriting = _parent.
_doneWriting
;
319
ValueTask.FromException(ChannelUtilities.CreateInvalidCompletionException(_parent.
_doneWriting
));
352
Debug.Assert(
_doneWriting
!= null, "We're completed, so we must be done writing.");
360
private bool ChannelIsClosedForDebugger =>
_doneWriting
!= null;