4 references to OfferMessage
System.Threading.Tasks.Dataflow (4)
Blocks\ActionBlock.cs (2)
276
_defaultTarget.
OfferMessage
(Common.SingleMessageHeader, item, null, false) == DataflowMessageStatus.Accepted :
284
_defaultTarget.
OfferMessage
(messageHeader, messageValue, source, consumeToAccept) :
Blocks\TransformBlock.cs (1)
367
return _target.
OfferMessage
(messageHeader, messageValue, source, consumeToAccept);
Blocks\TransformManyBlock.cs (1)
576
return _target.
OfferMessage
(messageHeader, messageValue, source, consumeToAccept);