4 writes to _blockedReadersHead
System.Threading.Channels (4)
System\Threading\Channels\UnboundedPriorityChannel.cs (4)
105ChannelUtilities.Enqueue(ref parent._blockedReadersHead, reader); 220parent._blockedReadersHead = null; 260blockedReader = ChannelUtilities.TryDequeueAndReserveCompletionIfCancelable(ref parent._blockedReadersHead); 321ChannelUtilities.Remove(ref state.Key._blockedReadersHead, blockedReader);
3 references to _blockedReadersHead
System.Threading.Channels (3)
System\Threading\Channels\UnboundedPriorityChannel.cs (3)
218blockedReadersHead = parent._blockedReadersHead; 347Debug.Assert(_blockedReadersHead is null, "There's data available, so there shouldn't be any blocked readers."); 353if ((_blockedReadersHead is not null || _waitingReadersHead is not null) && _runContinuationsAsynchronously)