1 write to _header
System.Threading.Tasks.Dataflow (1)
Blocks\WriteOnceBlock.cs (1)
369_header = Common.SingleMessageHeader;
11 references to _header
System.Threading.Tasks.Dataflow (11)
Blocks\WriteOnceBlock.cs (11)
130this, taskForOutputProcessing, DataflowEtwProvider.TaskLaunchedReason.OfferingOutputMessages, _header.IsValid ? 1 : 0); 270if (_header.IsValid && (filter == null || filter(_value!))) 333target.OfferMessage(_header, _value!, this, consumeToAccept: useCloning); 395if (_header.Id == messageHeader.Id) 417return _header.Id == messageHeader.Id; 428if (_header.Id != messageHeader.Id) throw new InvalidOperationException(SR.InvalidOperation_MessageNotReservedByTarget); 437Debug.Assert(_header.IsValid, "A valid header is required."); 439target.OfferMessage(_header, _value!, this, consumeToAccept: useCloning); 475target.OfferMessage(_header, _value!, this, consumeToAccept: useCloning); 510private bool HasValue { get { return _header.IsValid; } } 512private T? Value { get { return _header.IsValid ? _value : default(T); } }