1 write to _items
System.Threading.Channels (1)
System\Threading\Channels\UnboundedPriorityChannel.cs (1)
43_items = new PriorityQueue<bool, T>(comparer);
15 references to _items
System.Threading.Channels (15)
System\Threading\Channels\UnboundedPriorityChannel.cs (15)
67public override int Count => _parent._items.Count; 83if (parent._items.TryDequeue(out _, out T? item)) 119if (parent._items.TryDequeue(out _, out item)) 135return parent._items.TryPeek(out _, out item); 143if (parent._doneWriting != null && parent._items.Count == 0) 163if (parent._items.Count != 0) 223completeTask = parent._items.Count == 0; 270parent._items.Enqueue(true, item); 322private int ItemsCountForDebugger => _parent._items.Count; 329private object SyncObj => _items; 337if (_items.Count != 0) 348Debug.Assert(_items.Count == 0, "There are blocked/waiting readers, so there shouldn't be any data available."); 357private int ItemsCountForDebugger => _items.Count; 366foreach ((bool _, T Priority) item in _items.UnorderedItems) 371list.Sort(_items.Comparer);