16 references to BatchBlock
System.Threading.Tasks.Dataflow (16)
Base\DataflowBlockOptions.cs (1)
334
/// <see cref="
BatchBlock
{T}"/>.
Blocks\BatchBlock.cs (15)
25
[DebuggerTypeProxy(typeof(
BatchBlock
<>.DebugView))]
33
/// <summary>Initializes this <see cref="
BatchBlock
{T}"/> with the specified batch size.</summary>
40
/// <summary>Initializes this <see cref="
BatchBlock
{T}"/> with the specified batch size, declining option, and block options.</summary>
42
/// <param name="dataflowBlockOptions">The options with which to configure this <see cref="
BatchBlock
{T}"/>.</param>
61
onItemsRemoved = static (owningSource, count) => ((
BatchBlock
<T>)owningSource)._target.OnItemsRemoved(count);
67
static owningSource => ((
BatchBlock
<T>)owningSource)._target.Complete(exception: null, dropPendingMessages: true, releaseReservedMessages: false),
83
var thisBlock = ((
BatchBlock
<T>)state!) as IDataflowBlock;
113
/// Triggers the <see cref="
BatchBlock
{T}"/> to initiate a batching operation even if the number
144
/// <summary>Gets the size of the batches generated by this <see cref="
BatchBlock
{T}"/>.</summary>
192
private readonly
BatchBlock
<T> _batchBlock;
200
public DebugView(
BatchBlock
<T> batchBlock)
252
private readonly
BatchBlock
<T> _owningBatch;
304
/// <param name="dataflowBlockOptions">The options with which to configure this <see cref="
BatchBlock
{T}"/>. Assumed to be immutable.</param>
307
internal BatchBlockTargetCore(
BatchBlock
<T> owningBatch, int batchSize, Action<T[]> batchCompletedAction, GroupingDataflowBlockOptions dataflowBlockOptions)
475
/// <summary>Gets the size of the batches generated by this <see cref="
BatchBlock
{T}"/>.</summary>