1 write to _doneWriting
System.Threading.Channels (1)
System\Threading\Channels\UnboundedChannel.cs (1)
207
parent.
_doneWriting
= error ?? ChannelUtilities.s_doneWritingSentinel;
13 references to _doneWriting
System.Threading.Channels (13)
System\Threading\Channels\UnboundedChannel.cs (13)
95
if (parent.
_doneWriting
is not null)
97
return ChannelUtilities.GetInvalidCompletionValueTask<T>(parent.
_doneWriting
);
129
if (parent.
_doneWriting
is not null && parent._items.IsEmpty)
132
ChannelUtilities.Complete(parent._completion, parent.
_doneWriting
);
161
if (parent.
_doneWriting
is not null)
163
return parent.
_doneWriting
!= ChannelUtilities.s_doneWritingSentinel ?
164
new ValueTask<bool>(Task.FromException<bool>(parent.
_doneWriting
)) :
201
if (parent.
_doneWriting
is not null)
248
if (parent.
_doneWriting
is not null)
279
Exception? doneWriting = _parent.
_doneWriting
;
290
new ValueTask(Task.FromException(ChannelUtilities.CreateInvalidCompletionException(_parent.
_doneWriting
)));
354
Debug.Assert(
_doneWriting
is not null, "We're completed, so we must be done writing.");
362
private bool ChannelIsClosedForDebugger =>
_doneWriting
is not null;