5 writes to _blockedWritersHead
System.Threading.Channels (5)
System\Threading\Channels\BoundedChannel.cs (5)
268
while (ChannelUtilities.TryDequeue(ref parent.
_blockedWritersHead
, out BlockedWriteAsyncOperation<T>? w))
336
parent.
_blockedWritersHead
= null;
580
ChannelUtilities.Enqueue(ref parent.
_blockedWritersHead
, singleton);
590
ChannelUtilities.Enqueue(ref parent.
_blockedWritersHead
, writer);
672
ChannelUtilities.Remove(ref state.Key.
_blockedWritersHead
, blockedWriter);
4 references to _blockedWritersHead
System.Threading.Channels (4)
System\Threading\Channels\BoundedChannel.cs (4)
332
blockedWritersHead = parent.
_blockedWritersHead
;
706
Debug.Assert(
_blockedWritersHead
is null, "There's space available, so there shouldn't be any blocked writers.");
713
Debug.Assert(
_blockedWritersHead
is null, "There shouldn't be any blocked writer if there's a blocked reader.");
716
if (
_blockedWritersHead
is not null)