2 references to CompleteEachTarget
System.Threading.Tasks.Dataflow (2)
Blocks\BatchedJoinBlock.cs (2)
319this, dataflowBlockOptions, static owningSource => ((BatchedJoinBlock<T1, T2, T3>)owningSource).CompleteEachTarget());
360dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((BatchedJoinBlock<T1, T2, T3>)state!).CompleteEachTarget(), this);