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