2 writes to ConsumedMessage
System.Threading.Tasks.Dataflow (2)
Blocks\JoinBlock.cs (2)
538
_nonGreedy.
ConsumedMessage
= new KeyValuePair<bool, T>(false, default(T)!);
681
_nonGreedy.
ConsumedMessage
= new KeyValuePair<bool, T>(true, consumedValue!);
6 references to ConsumedMessage
System.Threading.Tasks.Dataflow (6)
Blocks\JoinBlock.cs (6)
536
Debug.Assert(_nonGreedy!.
ConsumedMessage
.Key, "A message must have been consumed by this point.");
537
T value = _nonGreedy.
ConsumedMessage
.Value;
566
return _nonGreedy!.
ConsumedMessage
.Key;
680
Debug.Assert(!_nonGreedy.
ConsumedMessage
.Key, "There must be no other consumed message");
743
_nonGreedy!.
ConsumedMessage
.Key ? 1 : 0;
953
private int InputCountForDebugger { get { return _messages != null ? _messages.Count : _nonGreedy!.
ConsumedMessage
.Key ? 1 : 0; } }