1 write to _items
System.Threading.Channels (1)
System\Threading\Channels\UnboundedPriorityChannel.cs (1)
46_items = new PriorityQueue<bool, T>(comparer);
15 references to _items
System.Threading.Channels (15)
System\Threading\Channels\UnboundedPriorityChannel.cs (15)
73public override int Count => _parent._items.Count; 89if (parent._items.TryDequeue(out _, out T? item)) 116if (parent._items.TryDequeue(out _, out item)) 132return parent._items.TryPeek(out _, out item); 140if (parent._doneWriting is not null && parent._items.Count == 0) 160if (parent._items.Count != 0) 214completeTask = parent._items.Count == 0; 265parent._items.Enqueue(true, item); 299private int ItemsCountForDebugger => _parent._items.Count; 306private object SyncObj => _items; 343if (_items.Count != 0) 355Debug.Assert(_items.Count == 0, "There are blocked/waiting readers, so there shouldn't be any data available."); 365private int ItemsCountForDebugger => _items.Count; 374foreach ((bool _, T Priority) item in _items.UnorderedItems) 379list.Sort(_items.Comparer);