1 reference to ProcessMessage
System.Threading.Tasks.Dataflow (1)
Blocks\TransformManyBlock.cs (1)
71
Initialize(messageWithId =>
ProcessMessage
(transform, messageWithId), dataflowBlockOptions, ref _source, ref _target, ref _reorderingBuffer, TargetCoreOptions.None);