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