1 write to _nextMessageId
System.Threading.Tasks.Dataflow (1)
Blocks\BroadcastBlock.cs (1)
742
header = new DataflowMessageHeader(++
_nextMessageId
);
4 references to _nextMessageId
System.Threading.Tasks.Dataflow (4)
Blocks\BroadcastBlock.cs (4)
687
DataflowMessageStatus result = target.OfferMessage(new DataflowMessageHeader(
_nextMessageId
), currentMessage!, _owningSource, consumeToAccept: useCloning);
1044
if (messageHeader.Id !=
_nextMessageId
)
1086
if (messageHeader.Id ==
_nextMessageId
)
1114
if (messageHeader.Id !=
_nextMessageId
) throw new InvalidOperationException(SR.InvalidOperation_MessageNotReservedByTarget);