1 write to _messages
System.Threading.Tasks.Dataflow (1)
Blocks\JoinBlock.cs (1)
520if (dbo.Greedy) _messages = new Queue<T>();
16 references to _messages
System.Threading.Tasks.Dataflow (16)
Blocks\JoinBlock.cs (16)
530Debug.Assert(_messages != null, "_messages must have been initialized in greedy mode"); 531Debug.Assert(_messages.Count >= 0, "A message must have been consumed by this point."); 532return _messages.Dequeue(); 561Debug.Assert(_messages != null, "_messages must have been initialized in greedy mode"); 562return _messages.Count > 0; 587return !_sharedResources._dataflowBlockOptions.Greedy ? _nonGreedy!.PostponedMessages.Count : _messages!.Count; 600int count = _messages!.Count; 725_messages!.Enqueue(consumedValue!); 742_messages!.Count : 798_messages?.Clear(); 862_messages!.Enqueue(messageValue!); 910Debug.Assert(_messages != null, "_messages must be initialized in greedy mode."); 911_messages.Clear(); 953private int InputCountForDebugger { get { return _messages != null ? _messages.Count : _nonGreedy!.ConsumedMessage.Key ? 1 : 0; } } 982public IEnumerable<T>? InputQueue { get { return _joinBlockTarget._messages; } }