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