1 write to _doneWriting
System.Threading.Channels (1)
System\Threading\Channels\BoundedChannel.cs (1)
326
parent.
_doneWriting
= error ?? ChannelUtilities.s_doneWritingSentinel;
16 references to _doneWriting
System.Threading.Channels (16)
System\Threading\Channels\BoundedChannel.cs (16)
167
if (parent.
_doneWriting
is not null)
169
return ChannelUtilities.GetInvalidCompletionValueTask<T>(parent.
_doneWriting
);
209
if (parent.
_doneWriting
is not null)
211
return parent.
_doneWriting
!= ChannelUtilities.s_doneWritingSentinel ?
212
new ValueTask<bool>(Task.FromException<bool>(parent.
_doneWriting
)) :
247
if (parent.
_doneWriting
is not null)
252
ChannelUtilities.Complete(parent._completion, parent.
_doneWriting
);
320
if (parent.
_doneWriting
is not null)
378
if (parent.
_doneWriting
is not null)
480
if (parent.
_doneWriting
is not null)
482
return parent.
_doneWriting
!= ChannelUtilities.s_doneWritingSentinel ?
483
new ValueTask<bool>(Task.FromException<bool>(parent.
_doneWriting
)) :
535
if (parent.
_doneWriting
is not null)
537
return new ValueTask(Task.FromException(ChannelUtilities.CreateInvalidCompletionException(parent.
_doneWriting
)));
724
Debug.Assert(
_doneWriting
is not null, "We can only complete if we're done writing.");
732
private bool ChannelIsClosedForDebugger =>
_doneWriting
is not null;