1 write to _header
System.Threading.Tasks.Dataflow (1)
Blocks\WriteOnceBlock.cs (1)
363_header = Common.SingleMessageHeader;
11 references to _header
System.Threading.Tasks.Dataflow (11)
Blocks\WriteOnceBlock.cs (11)
127this, taskForOutputProcessing, DataflowEtwProvider.TaskLaunchedReason.OfferingOutputMessages, _header.IsValid ? 1 : 0); 264if (_header.IsValid && (filter == null || filter(_value!))) 321target.OfferMessage(_header, _value!, this, consumeToAccept: useCloning); 388if (_header.Id == messageHeader.Id) 410return _header.Id == messageHeader.Id; 421if (_header.Id != messageHeader.Id) throw new InvalidOperationException(SR.InvalidOperation_MessageNotReservedByTarget); 430Debug.Assert(_header.IsValid, "A valid header is required."); 432target.OfferMessage(_header, _value!, this, consumeToAccept: useCloning); 468target.OfferMessage(_header, _value!, this, consumeToAccept: useCloning); 503private bool HasValue { get { return _header.IsValid; } } 505private T? Value { get { return _header.IsValid ? _value : default(T); } }