7 references to _blockedReaders
System.Threading.Channels (7)
System\Threading\Channels\UnboundedChannel.cs (7)
101
parent.
_blockedReaders
.EnqueueTail(singleton);
108
parent.
_blockedReaders
.EnqueueTail(reader);
234
ChannelUtilities.FailOperations<AsyncOperation<T>, T>(parent.
_blockedReaders
, ChannelUtilities.CreateInvalidCompletionException(error));
263
if (parent.
_blockedReaders
.IsEmpty)
276
blockedReader = parent.
_blockedReaders
.DequeueHead();
336
Debug.Assert(
_blockedReaders
.IsEmpty, "There's data available, so there shouldn't be any blocked readers.");
341
if ((!
_blockedReaders
.IsEmpty || _waitingReadersTail != null) && _runContinuationsAsynchronously)