11 references to BatchedJoinBlock
System.Threading.Tasks.Dataflow (11)
Blocks\BatchedJoinBlock.cs (11)
28[DebuggerTypeProxy(typeof(BatchedJoinBlock<,>.DebugView))]
42/// <summary>Initializes this <see cref="BatchedJoinBlock{T1,T2}"/> with the specified configuration.</summary>
49/// <summary>Initializes this <see cref="BatchedJoinBlock{T1,T2}"/> with the specified configuration.</summary>
51/// <param name="dataflowBlockOptions">The options with which to configure this <see cref="BatchedJoinBlock{T1,T2}"/>.</param>
68this, dataflowBlockOptions, static owningSource => ((BatchedJoinBlock<T1, T2>)owningSource).CompleteEachTarget());
101var thisBlock = ((BatchedJoinBlock<T1, T2>)state!) as IDataflowBlock;
108dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((BatchedJoinBlock<T1, T2>)state!).CompleteEachTarget(), this);
116/// <summary>Gets the size of the batches generated by this <see cref="BatchedJoinBlock{T1,T2}"/>.</summary>
222private readonly BatchedJoinBlock<T1, T2> _batchedJoinBlock;
228public DebugView(BatchedJoinBlock<T1, T2> batchedJoinBlock)
299/// <param name="dataflowBlockOptions">The options with which to configure this <see cref="BatchedJoinBlock{T1,T2}"/>.</param>