19 references to _items
System.Threading.Channels (19)
System\Threading\Channels\UnboundedChannel.cs (19)
66
public override int Count => _parent.
_items
.Count;
77
if (parent.
_items
.TryDequeue(out T? item))
88
if (parent.
_items
.TryDequeue(out item))
114
if (parent.
_items
.TryDequeue(out item))
125
_parent.
_items
.TryPeek(out item);
129
if (parent._doneWriting is not null && parent.
_items
.IsEmpty)
143
if (!_parent.
_items
.IsEmpty)
155
if (!parent.
_items
.IsEmpty)
178
IEnumerator<T> IDebugEnumerable<T>.GetEnumerator() => _parent.
_items
.GetEnumerator();
208
completeTask = parent.
_items
.IsEmpty;
239
if (!completeTask && parent.
_items
.IsEmpty)
269
parent.
_items
.Enqueue(item);
303
private int ItemsCountForDebugger => _parent.
_items
.Count;
306
IEnumerator<T> IDebugEnumerable<T>.GetEnumerator() => _parent.
_items
.GetEnumerator();
310
private object SyncObj =>
_items
;
347
if (!
_items
.IsEmpty)
359
Debug.Assert(
_items
.IsEmpty, "There are blocked/waiting readers, so there shouldn't be any data available.");
369
private int ItemsCountForDebugger =>
_items
.Count;
375
IEnumerator<T> IDebugEnumerable<T>.GetEnumerator() =>
_items
.GetEnumerator();