9 references to BatchedJoinBlock
System.Threading.Tasks.Dataflow (9)
Blocks\BatchedJoinBlock.cs (9)
274[DebuggerTypeProxy(typeof(BatchedJoinBlock<,,>.DebugView))]
290/// <summary>Initializes this <see cref="BatchedJoinBlock{T1,T2,T3}"/> with the specified configuration.</summary>
297/// <summary>Initializes this <see cref="BatchedJoinBlock{T1,T2,T3}"/> with the specified configuration.</summary>
319this, dataflowBlockOptions, static owningSource => ((BatchedJoinBlock<T1, T2, T3>)owningSource).CompleteEachTarget());
353var thisBlock = ((BatchedJoinBlock<T1, T2, T3>)state!) as IDataflowBlock;
360dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((BatchedJoinBlock<T1, T2, T3>)state!).CompleteEachTarget(), this);
368/// <summary>Gets the size of the batches generated by this <see cref="BatchedJoinBlock{T1,T2,T3}"/>.</summary>
480private readonly BatchedJoinBlock<T1, T2, T3> _batchedJoinBlock;
486public DebugView(BatchedJoinBlock<T1, T2, T3> batchedJoinBlock)