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