1 write to _header
System.Threading.Tasks.Dataflow (1)
Blocks\WriteOnceBlock.cs (1)
357_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); 383if (_header.Id == messageHeader.Id) 405return _header.Id == messageHeader.Id; 416if (_header.Id != messageHeader.Id) throw new InvalidOperationException(SR.InvalidOperation_MessageNotReservedByTarget); 425Debug.Assert(_header.IsValid, "A valid header is required."); 427target.OfferMessage(_header, _value!, this, consumeToAccept: useCloning); 463target.OfferMessage(_header, _value!, this, consumeToAccept: useCloning); 498private bool HasValue { get { return _header.IsValid; } } 500private T? Value { get { return _header.IsValid ? _value : default(T); } }