added interval option to processSortedSet

8 years ago · b4b68498cd
parent 1f5b3ba636
commit b4b68498cd
1 changed files with 5 additions and 1 deletions
--- a/src/batch.js
+++ b/src/batch.js
@ -63,7 +63,11 @@ exports.processSortedSet = function (setKey, process, options, callback) {
 					start += utils.isNumber(options.alwaysStartAt) ? options.alwaysStartAt : batch + 1;
 					stop = start + batch;

-					next();
+					if (options.interval) {
+						setTimeout(next, options.interval);
+					} else {
+						next();
+					}
 				});
 			});
 		},