A B C M W

A

accept(K, I, Consumer<Collection<I>>) - Method in class won.utils.batch.BatchingConsumer

accept(K, I, Consumer<Collection<I>>, BatchingConsumer.Config) - Method in class won.utils.batch.BatchingConsumer

accept(K, I, String, Consumer<Collection<I>>) - Method in class won.utils.batch.BatchingConsumer

accept(K, I, String, Consumer<Collection<I>>, BatchingConsumer.Config) - Method in class won.utils.batch.BatchingConsumer

accept(K, I, Optional<String>, Consumer<Collection<I>>, Optional<BatchingConsumer.Config>) - Method in class won.utils.batch.BatchingConsumer

Offer an item to the BatchingConsumer, providing an optional deduplicationKey, a consumer and an optional config.

B

BatchingConsumer<K,I> - Class in won.utils.batch

Accepts items together with a key for grouping them, a Consumer<Collection<Object>> for consuming them.

BatchingConsumer() - Constructor for class won.utils.batch.BatchingConsumer

BatchingConsumer(BatchingConsumer.Config) - Constructor for class won.utils.batch.BatchingConsumer

BatchingConsumer.Config - Class in won.utils.batch

BatchingConsumer.ConfigBuilder - Class in won.utils.batch

build() - Method in class won.utils.batch.BatchingConsumer.ConfigBuilder

C

cancelBatch(K) - Method in class won.utils.batch.BatchingConsumer

Removes the batch, the consumer is not invoked.

Config(Optional<Duration>, Optional<Duration>, Optional<Duration>, Optional<Boolean>, Optional<Integer>) - Constructor for class won.utils.batch.BatchingConsumer.Config

ConfigBuilder() - Constructor for class won.utils.batch.BatchingConsumer.ConfigBuilder

consumeAllBatches() - Method in class won.utils.batch.BatchingConsumer

Invokes the consumers for all batches immediately and removes all batches.

consumeFirst - Variable in class won.utils.batch.BatchingConsumer.Config

consumeFirst(Boolean) - Method in class won.utils.batch.BatchingConsumer.ConfigBuilder

M

maxBatchAge - Variable in class won.utils.batch.BatchingConsumer.Config

maxBatchAge(Duration) - Method in class won.utils.batch.BatchingConsumer.ConfigBuilder

maxBatchSize - Variable in class won.utils.batch.BatchingConsumer.Config

maxBatchSize(Integer) - Method in class won.utils.batch.BatchingConsumer.ConfigBuilder

maxItemInterval - Variable in class won.utils.batch.BatchingConsumer.Config

maxItemInterval(Duration) - Method in class won.utils.batch.BatchingConsumer.ConfigBuilder

minChunkInterval - Variable in class won.utils.batch.BatchingConsumer.Config

minChunkInterval(Duration) - Method in class won.utils.batch.BatchingConsumer.ConfigBuilder

W

won.utils.batch - package won.utils.batch

A B C M W