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