1 instantiation of BatchBlockTargetCore
System.Threading.Tasks.Dataflow (1)
Blocks\BatchBlock.cs (1)
71_target = new BatchBlockTargetCore(this, batchSize, _source.AddMessage, dataflowBlockOptions);
9 references to BatchBlockTargetCore
System.Threading.Tasks.Dataflow (9)
Blocks\BatchBlock.cs (9)
29private readonly BatchBlockTargetCore _target; 62itemCountingFunc = static (owningSource, singleOutputItem, multipleOutputItems) => BatchBlockTargetCore.CountItems(singleOutputItem, multipleOutputItems); 90dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((BatchBlockTargetCore)state!).Complete(exception: null, dropPendingMessages: true, releaseReservedMessages: false), _target); 194private readonly BatchBlockTargetCore.DebuggingInformation _targetDebuggingInformation; 527var targetCore = (BatchBlockTargetCore)thisTargetCore!; 641_nonGreedyState!.TaskForInputProcessing = new Task(static thisBatchTarget => ((BatchBlockTargetCore)thisBatchTarget!).ProcessMessagesLoopCore(), this, 1173private readonly BatchBlockTargetCore _target; 1177public DebuggingInformation(BatchBlockTargetCore target) { _target = target; }