8 references to ConsumeMessage
System.Threading.Tasks.Dataflow (8)
Blocks\BatchBlock.cs (1)
160
return _source.
ConsumeMessage
(messageHeader, target, out messageConsumed);
Blocks\BatchedJoinBlock.cs (2)
179
return _source.
ConsumeMessage
(messageHeader, target, out messageConsumed);
436
return _source.
ConsumeMessage
(messageHeader, target, out messageConsumed);
Blocks\BufferBlock.cs (1)
206
return _source.
ConsumeMessage
(messageHeader, target, out messageConsumed);
Blocks\JoinBlock.cs (2)
171
return _source.
ConsumeMessage
(messageHeader, target, out messageConsumed);
401
return _source.
ConsumeMessage
(messageHeader, target, out messageConsumed);
Blocks\TransformBlock.cs (1)
379
return _source.
ConsumeMessage
(messageHeader, target, out messageConsumed);
Blocks\TransformManyBlock.cs (1)
585
return _source.
ConsumeMessage
(messageHeader, target, out messageConsumed);