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