34 references to _items
System.Threading.Channels (34)
System\Threading\Channels\BoundedChannel.cs (34)
39
private object SyncObj =>
_items
;
87
return parent.
_items
.Count;
97
private int ItemsCountForDebugger => _parent.
_items
.Count;
107
if (!parent.
_items
.IsEmpty)
126
if (!parent.
_items
.IsEmpty)
128
item = parent.
_items
.PeekHead();
150
if (!parent.
_items
.IsEmpty)
200
if (!parent.
_items
.IsEmpty)
249
T item = parent.
_items
.DequeueHead();
254
if (parent.
_items
.IsEmpty)
278
parent.
_items
.EnqueueTail(w.Item!);
293
IEnumerator<T> IDebugEnumerable<T>.GetEnumerator() => _parent.
_items
.GetEnumerator();
327
completeTask = parent.
_items
.IsEmpty;
375
int count = parent.
_items
.Count;
398
parent.
_items
.EnqueueTail(item);
412
parent.
_items
.EnqueueTail(item);
435
parent.
_items
.DequeueTail() :
436
parent.
_items
.DequeueHead();
438
parent.
_items
.EnqueueTail(item);
499
if (parent.
_items
.Count < parent._bufferedCapacity || parent._mode != BoundedChannelFullMode.Wait)
550
int count = parent.
_items
.Count;
573
parent.
_items
.EnqueueTail(item);
587
parent.
_items
.EnqueueTail(item);
626
parent.
_items
.DequeueTail() :
627
parent.
_items
.DequeueHead();
629
parent.
_items
.EnqueueTail(item);
666
private int ItemsCountForDebugger => _parent.
_items
.Count;
672
IEnumerator<T> IDebugEnumerable<T>.GetEnumerator() => _parent.
_items
.GetEnumerator();
681
if (!
_items
.IsEmpty)
686
if (
_items
.Count < _bufferedCapacity)
693
Debug.Assert(
_items
.IsEmpty, "There shouldn't be queued items if there's a blocked reader.");
698
Debug.Assert(
_items
.Count == _bufferedCapacity, "We should have a full buffer if there's a blocked writer.");
708
private int ItemsCountForDebugger =>
_items
.Count;
714
IEnumerator<T> IDebugEnumerable<T>.GetEnumerator() =>
_items
.GetEnumerator();