20 references to _messages
System.Threading.Tasks.Dataflow (20)
Internal\SourceCore.cs (20)
191!_messages.TryDequeue(out consumedMessageValue)) 233if (messageHeader.Id == _nextMessageId.Value && !_messages.IsEmpty) 260if (messageHeader.Id != _nextMessageId.Value || _messages.IsEmpty) throw new InvalidOperationException(SR.InvalidOperation_MessageNotReservedByTarget); 295if (_messages.TryDequeueIf(filter, out item)) 340if (!_messages.IsEmpty) 345while (_messages.TryDequeue(out item)) tmpList.Add(item); 379internal int OutputCount { get { lock (OutgoingLock) lock (ValueLock) return _messages.Count; } } 393_messages.Enqueue(item); 428_messages.Enqueue(itemsAsList[i]); 438_messages.Enqueue(itemsAsArray[i]); 445_messages.Enqueue(item); 566if (_messages.TryPeek(out message)) 626!_messages.TryDequeue(out dropped)) // remove the next message 728if (_taskForOutputProcessing == null && _enableOffering && !_messages.IsEmpty) 741Debug.Assert(_taskForOutputProcessing == null && _enableOffering && !_messages.IsEmpty, 766_owningSource, _taskForOutputProcessing, DataflowEtwProvider.TaskLaunchedReason.OfferingOutputMessages, _messages.Count); 918if (_messages.IsEmpty || CanceledOrFaulted) 947_messages.Clear(); 1007internal int OutputCount { get { return _source._messages.Count; } } 1009internal IEnumerable<TOutput> OutputQueue { get { return _source._messages.ToList(); } }