3 references to Initialize
System.Threading.Tasks.Dataflow (3)
Blocks\TransformManyBlock.cs (2)
71
Initialize
(messageWithId => ProcessMessage(transform, messageWithId), dataflowBlockOptions, ref _source, ref _target, ref _reorderingBuffer, TargetCoreOptions.None);
95
Initialize
(messageWithId => ProcessMessageWithTask(transform, messageWithId), dataflowBlockOptions, ref _source, ref _target, ref _reorderingBuffer, TargetCoreOptions.UsesAsyncCompletion);
Blocks\TransformManyBlock.IAsyncEnumerable.cs (1)
37
Initialize
(messageWithId =>