Implemented interface member:
property
IsEmpty
System.Collections.Concurrent.IProducerConsumerQueue<T>.IsEmpty
9 references to IsEmpty
System.Threading.Tasks.Dataflow (9)
Internal\SourceCore.cs (6)
233
if (messageHeader.Id == _nextMessageId.Value && !_messages.
IsEmpty
)
260
if (messageHeader.Id != _nextMessageId.Value || _messages.
IsEmpty
) throw new InvalidOperationException(SR.InvalidOperation_MessageNotReservedByTarget);
340
if (!_messages.
IsEmpty
)
728
if (_taskForOutputProcessing == null && _enableOffering && !_messages.
IsEmpty
)
741
Debug.Assert(_taskForOutputProcessing == null && _enableOffering && !_messages.
IsEmpty
,
918
if (_messages.
IsEmpty
|| CanceledOrFaulted)
Internal\SpscTargetCore.cs (3)
234
if (!_messages.
IsEmpty
&& _exceptions == null && (messagesProcessed < maxMessagesToProcess))
243
if ((wasDecliningPermanently && _messages.
IsEmpty
) || _exceptions != null)
265
if (!_messages.
IsEmpty
|| // messages to be processed
