4 writes to _waitingReadersHead
System.Threading.Channels (4)
System\Threading\Channels\UnboundedChannel.cs (4)
172
ChannelUtilities.Enqueue(ref parent.
_waitingReadersHead
, waiter);
215
parent.
_waitingReadersHead
= null;
260
waitingReadersHead = ChannelUtilities.TryReserveCompletionIfCancelable(ref parent.
_waitingReadersHead
);
319
ChannelUtilities.Remove(ref state.Key.
_waitingReadersHead
, waitingReader);
3 references to _waitingReadersHead
System.Threading.Channels (3)
System\Threading\Channels\UnboundedChannel.cs (3)
213
waitingReadersHead = parent.
_waitingReadersHead
;
342
Debug.Assert(
_waitingReadersHead
is null, "There's data available, so there shouldn't be any waiting readers.");
347
if ((_blockedReadersHead is not null ||
_waitingReadersHead
is not null) && _runContinuationsAsynchronously)