对象 Batcher

主要用于 @emartech/rabbitmq-client是批量的消费者.

使用量

初始化

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

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

调用函数将在 batchTimeout 过期或按下的项目计数到达集合 batchSize 或总推出项数达到给定 prefecthCount。 。 。 .

将项目推入对象批发器

objectBatcher.add(groupBy, payload);

同一组的不同有效载荷将进行分批处理,并使用 (groupBy, payloads) 参数.

重置批量器状态

objectBatcher.resetState();

这种方法在测试中大多有用. 在每次测试之前你可以打电话 resetState 确保剩余部分 状态从上一个运行不会干扰当前运行.

将所有依赖性更新到最高, 以创建新发行 如果您想要新的释放, 承诺必须从“ 固定( ...) ” 或“ feat( ...) ” 开始

版权:EMARSYS 2020 版权所有.