1 write to _messages
System.Threading.Tasks.Dataflow (1)
Blocks\JoinBlock.cs (1)
508if (dbo.Greedy) _messages = new Queue<T>();
16 references to _messages
System.Threading.Tasks.Dataflow (16)
Blocks\JoinBlock.cs (16)
518Debug.Assert(_messages != null, "_messages must have been initialized in greedy mode"); 519Debug.Assert(_messages.Count >= 0, "A message must have been consumed by this point."); 520return _messages.Dequeue(); 549Debug.Assert(_messages != null, "_messages must have been initialized in greedy mode"); 550return _messages.Count > 0; 575return !_sharedResources._dataflowBlockOptions.Greedy ? _nonGreedy!.PostponedMessages.Count : _messages!.Count; 588int count = _messages!.Count; 713_messages!.Enqueue(consumedValue!); 730_messages!.Count : 786_messages?.Clear(); 850_messages!.Enqueue(messageValue!); 898Debug.Assert(_messages != null, "_messages must be initialized in greedy mode."); 899_messages.Clear(); 938private int InputCountForDebugger { get { return _messages != null ? _messages.Count : _nonGreedy!.ConsumedMessage.Key ? 1 : 0; } } 967public IEnumerable<T>? InputQueue { get { return _joinBlockTarget._messages; } }