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