10 references to _messages
System.Threading.Tasks.Dataflow (10)
Internal\SpscTargetCore.cs (10)
92_messages.Enqueue(messageValue); 149_messages.Enqueue(messageValue!); 177_owningTarget, newConsumer, DataflowEtwProvider.TaskLaunchedReason.ProcessingInputMessages, _messages.Count); 213_messages.TryDequeue(out nextMessage)) 234if (!_messages.IsEmpty && _exceptions == null && (messagesProcessed < maxMessagesToProcess)) 243if ((wasDecliningPermanently && _messages.IsEmpty) || _exceptions != null) 265if (!_messages.IsEmpty || // messages to be processed 278internal int InputCount { get { return _messages.Count; } } 327while (_messages.TryDequeue(out _)) ; 391internal IEnumerable<TInput> InputQueue { get { return _target._messages.ToList(); } }