3 writes to ReservedMessage
System.Threading.Tasks.Dataflow (3)
Blocks\JoinBlock.cs (3)
622_nonGreedy.ReservedMessage = next; 648_nonGreedy.ReservedMessage = default(KeyValuePair<ISourceBlock<T>, DataflowMessageHeader>); 770_nonGreedy.ReservedMessage = default(KeyValuePair<ISourceBlock<T>, DataflowMessageHeader>);
7 references to ReservedMessage
System.Threading.Tasks.Dataflow (7)
Blocks\JoinBlock.cs (7)
642Debug.Assert(_nonGreedy!.ReservedMessage.Key != null, "This target must have a reserved message"); 645T? consumedValue = _nonGreedy.ReservedMessage.Key.ConsumeMessage(_nonGreedy.ReservedMessage.Value, this, out consumed); 756if (_nonGreedy != null && _nonGreedy.ReservedMessage.Key != null) 759try { _nonGreedy.ReservedMessage.Key.ReleaseReservation(_nonGreedy.ReservedMessage.Value, this); } 779Debug.Assert(_nonGreedy == null || _nonGreedy.ReservedMessage.Key == null,