4 writes to _waitingReadersHead
System.Threading.Channels (4)
System\Threading\Channels\UnboundedPriorityChannel.cs (4)
177ChannelUtilities.Enqueue(ref parent._waitingReadersHead, waiter); 221parent._waitingReadersHead = null; 266waitingReadersHead = ChannelUtilities.TryReserveCompletionIfCancelable(ref parent._waitingReadersHead); 325ChannelUtilities.Remove(ref state.Key._waitingReadersHead, waitingReader);
3 references to _waitingReadersHead
System.Threading.Channels (3)
System\Threading\Channels\UnboundedPriorityChannel.cs (3)
219waitingReadersHead = parent._waitingReadersHead; 348Debug.Assert(_waitingReadersHead is null, "There's data available, so there shouldn't be any waiting readers."); 353if ((_blockedReadersHead is not null || _waitingReadersHead is not null) && _runContinuationsAsynchronously)