3 writes to ReservedMessage
System.Threading.Tasks.Dataflow (3)
Blocks\JoinBlock.cs (3)
634_nonGreedy.ReservedMessage = next; 660_nonGreedy.ReservedMessage = default(KeyValuePair<ISourceBlock<T>, DataflowMessageHeader>); 782_nonGreedy.ReservedMessage = default(KeyValuePair<ISourceBlock<T>, DataflowMessageHeader>);
7 references to ReservedMessage
System.Threading.Tasks.Dataflow (7)
Blocks\JoinBlock.cs (7)
654Debug.Assert(_nonGreedy!.ReservedMessage.Key != null, "This target must have a reserved message"); 657T? consumedValue = _nonGreedy.ReservedMessage.Key.ConsumeMessage(_nonGreedy.ReservedMessage.Value, this, out consumed); 768if (_nonGreedy != null && _nonGreedy.ReservedMessage.Key != null) 771try { _nonGreedy.ReservedMessage.Key.ReleaseReservation(_nonGreedy.ReservedMessage.Value, this); } 791Debug.Assert(_nonGreedy == null || _nonGreedy.ReservedMessage.Key == null,