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