won.utils.batch

Class BatchingConsumer.ConfigBuilder

java.lang.Object

won.utils.batch.BatchingConsumer.ConfigBuilder

Enclosing class:

BatchingConsumer<K,I>

public static class BatchingConsumer.ConfigBuilder
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ConfigBuilder()

Method Summary

Modifier and Type	Method and Description
BatchingConsumer.Config	build()
BatchingConsumer.ConfigBuilder	consumeFirst(java.lang.Boolean b)
BatchingConsumer.ConfigBuilder	maxBatchAge(java.time.Duration d)
BatchingConsumer.ConfigBuilder	maxBatchSize(java.lang.Integer s)
BatchingConsumer.ConfigBuilder	maxItemInterval(java.time.Duration d)
BatchingConsumer.ConfigBuilder	minChunkInterval(java.time.Duration d)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConfigBuilder

public ConfigBuilder()

Method Detail

maxBatchAge

public BatchingConsumer.ConfigBuilder maxBatchAge(java.time.Duration d)

maxItemInterval

public BatchingConsumer.ConfigBuilder maxItemInterval(java.time.Duration d)

consumeFirst

public BatchingConsumer.ConfigBuilder consumeFirst(java.lang.Boolean b)

minChunkInterval

public BatchingConsumer.ConfigBuilder minChunkInterval(java.time.Duration d)

maxBatchSize

public BatchingConsumer.ConfigBuilder maxBatchSize(java.lang.Integer s)

build

public BatchingConsumer.Config build()