4 references to DataflowMessageHeader
System.Threading.Tasks.Dataflow (4)
Blocks\BroadcastBlock.cs (2)
687
DataflowMessageStatus result = target.OfferMessage(new
DataflowMessageHeader
(_nextMessageId), currentMessage!, _owningSource, consumeToAccept: useCloning);
742
header = new
DataflowMessageHeader
(++_nextMessageId);
Internal\Common.cs (1)
34
internal static readonly DataflowMessageHeader SingleMessageHeader = new
DataflowMessageHeader
(SINGLE_MESSAGE_ID);
Internal\SourceCore.cs (1)
562
header = new
DataflowMessageHeader
(_nextMessageId.Value);