14 references to _messages
System.Threading.Tasks.Dataflow (14)
Blocks\BroadcastBlock.cs (14)
622_messages.Enqueue(item); 623if (_messages.Count == 1) _enableOffering = true; 724if (_nextMessageReservedFor == null && _messages.Count > 0) 730while (_messages.Count > 1) 732_messages.Dequeue(); 738Debug.Assert(_messages.Count > 0, "There must be at least one message to dequeue."); 739_currentMessage = message = _messages.Dequeue(); 743if (_messages.Count == 0) _enableOffering = false; 824bool processingToDo = _enableOffering && _messages.Count > 0; 838_owningSource, _taskForOutputProcessing, DataflowEtwProvider.TaskLaunchedReason.OfferingOutputMessages, _messages.Count); 921bool noMoreMessages = _decliningPermanently && _messages.Count == 0; 940(_decliningPermanently && _messages.Count == 0) || CanceledOrFaulted, 967_messages.Clear(); 1208public IEnumerable<TOutput> InputQueue { get { return _source._messages.ToList(); } }