1 write to _doneWriting
System.Threading.Channels (1)
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (1)
225
parent.
_doneWriting
= error ?? ChannelUtilities.s_doneWritingSentinel;
12 references to _doneWriting
System.Threading.Channels (12)
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (12)
94
if (parent.
_doneWriting
!= null)
96
return ChannelUtilities.GetInvalidCompletionValueTask<T>(parent.
_doneWriting
);
128
if (parent.
_doneWriting
!= null && parent._items.IsEmpty)
130
ChannelUtilities.Complete(parent._completion, parent.
_doneWriting
);
164
if (parent.
_doneWriting
!= null)
166
return parent.
_doneWriting
!= ChannelUtilities.s_doneWritingSentinel ?
167
new ValueTask<bool>(Task.FromException<bool>(parent.
_doneWriting
)) :
219
if (parent.
_doneWriting
!= null)
292
if (parent.
_doneWriting
!= null)
342
Exception? doneWriting = _parent.
_doneWriting
;
355
new ValueTask(Task.FromException(ChannelUtilities.CreateInvalidCompletionException(_parent.
_doneWriting
)));
370
private bool ChannelIsClosedForDebugger =>
_doneWriting
!= null;