20 references to _messages
System.Threading.Tasks.Dataflow (20)
Internal\SourceCore.cs (20)
185!_messages.TryDequeue(out consumedMessageValue)) 227if (messageHeader.Id == _nextMessageId.Value && !_messages.IsEmpty) 254if (messageHeader.Id != _nextMessageId.Value || _messages.IsEmpty) throw new InvalidOperationException(SR.InvalidOperation_MessageNotReservedByTarget); 289if (_messages.TryDequeueIf(filter, out item)) 334if (!_messages.IsEmpty) 339while (_messages.TryDequeue(out item)) tmpList.Add(item); 373internal int OutputCount { get { lock (OutgoingLock) lock (ValueLock) return _messages.Count; } } 387_messages.Enqueue(item); 422_messages.Enqueue(itemsAsList[i]); 432_messages.Enqueue(itemsAsArray[i]); 439_messages.Enqueue(item); 560if (_messages.TryPeek(out message)) 620!_messages.TryDequeue(out dropped)) // remove the next message 722if (_taskForOutputProcessing == null && _enableOffering && !_messages.IsEmpty) 735Debug.Assert(_taskForOutputProcessing == null && _enableOffering && !_messages.IsEmpty, 760_owningSource, _taskForOutputProcessing, DataflowEtwProvider.TaskLaunchedReason.OfferingOutputMessages, _messages.Count); 912if (_messages.IsEmpty || CanceledOrFaulted) 941_messages.Clear(); 1001internal int OutputCount { get { return _source._messages.Count; } } 1003internal IEnumerable<TOutput> OutputQueue { get { return _source._messages.ToList(); } }