Class AccumulatingBatchReceiver<T> (2.33.0)

public final class AccumulatingBatchReceiver<T> implements ThresholdBatchReceiver<T>

A simple ThresholdBatchReceiver that just accumulates batches.

Inheritance

java.lang.Object > AccumulatingBatchReceiver<T>

com.google.api.gax.batching.ThresholdBatchReceiver<T>

Type Parameter
Name	Description
`T`

public AccumulatingBatchReceiver(ApiFuture<?> retFuture)

Parameter
Name	Description
`retFuture`	`ApiFuture<?>`

public List<T> getBatches()

Returns the accumulated batches. If called concurrently with processBatch, the new batch may or may not be returned.

Returns
Type	Description
`List<T>`

public ApiFuture<?> processBatch(T batch)

Parameter
Name	Description
`batch`	`T`

Returns
Type	Description
`ApiFuture<?>`

public void validateBatch(T message)

Parameter
Name	Description
`message`	`T`