Object Batcher

Used primarily by @emartech/rabbitmq-client's batch consumer.

Usage

Initialize

const ObjectBatcher = require('@emartech/object-batcher-js');

const objectBatcher = new ObjectBatcher(callback_fn, {
  batchSize,
  batchTimeout,
  [prefetchCount]
});

The callback function will be called after the batchTimeout expires or the pushed items count reaches the set batchSize or the overall pushed items count reaches the given prefecthCount.

Pushing an item into the object batcher

objectBatcher.add(groupBy, payload);

Different payloads with the same groups will be batched and the callback will be called with (groupBy, payloads) arguments.

Reseting state of batcher

objectBatcher.resetState();

This method is mostly useful during testing. Before each test case you could call resetState to ensure the leftover state from previous run does not interfere with the current one.

updating all dependencies to highest to create new release if you want new release the commits have to begin with "fix(...)" or "feat(...)"

Copyright EMARSYS 2020 All rights reserved.