fix: redis batch

4 years ago · 0c4b875e10
parent 3261edcc32
commit 0c4b875e10
1 changed files with 2 additions and 2 deletions
--- a/src/batch.js
+++ b/src/batch.js
@ -47,8 +47,8 @@ exports.processSortedSet = async function (setKey, process, options) {
 		}
 		await process(ids);

-		start += utils.isNumber(options.alwaysStartAt) ? options.alwaysStartAt : options.batch + 1;
-		stop = start + options.batch;
+		start += utils.isNumber(options.alwaysStartAt) ? options.alwaysStartAt : options.batch;
+		stop = start + options.batch - 1;

 		if (options.interval) {
 			await sleep(options.interval);