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