14 references to _messages
System.Threading.Tasks.Dataflow (14)
Blocks\BroadcastBlock.cs (14)
628_messages.Enqueue(item); 629if (_messages.Count == 1) _enableOffering = true; 730if (_nextMessageReservedFor == null && _messages.Count > 0) 736while (_messages.Count > 1) 738_messages.Dequeue(); 744Debug.Assert(_messages.Count > 0, "There must be at least one message to dequeue."); 745_currentMessage = message = _messages.Dequeue(); 749if (_messages.Count == 0) _enableOffering = false; 830bool processingToDo = _enableOffering && _messages.Count > 0; 844_owningSource, _taskForOutputProcessing, DataflowEtwProvider.TaskLaunchedReason.OfferingOutputMessages, _messages.Count); 927bool noMoreMessages = _decliningPermanently && _messages.Count == 0; 946(_decliningPermanently && _messages.Count == 0) || CanceledOrFaulted, 973_messages.Clear(); 1220public IEnumerable<TOutput> InputQueue { get { return _source._messages.ToList(); } }