8 references to ConsumeMessage
System.Threading.Tasks.Dataflow (8)
Blocks\BatchBlock.cs (1)
157
return _source.
ConsumeMessage
(messageHeader, target, out messageConsumed);
Blocks\BatchedJoinBlock.cs (2)
176
return _source.
ConsumeMessage
(messageHeader, target, out messageConsumed);
430
return _source.
ConsumeMessage
(messageHeader, target, out messageConsumed);
Blocks\BufferBlock.cs (1)
200
return _source.
ConsumeMessage
(messageHeader, target, out messageConsumed);
Blocks\JoinBlock.cs (2)
165
return _source.
ConsumeMessage
(messageHeader, target, out messageConsumed);
389
return _source.
ConsumeMessage
(messageHeader, target, out messageConsumed);
Blocks\TransformBlock.cs (1)
373
return _source.
ConsumeMessage
(messageHeader, target, out messageConsumed);
Blocks\TransformManyBlock.cs (1)
582
return _source.
ConsumeMessage
(messageHeader, target, out messageConsumed);