async with limit

This commit is contained in:
Aliaksei Chapyzhenka 2019-10-21 18:53:43 -07:00
parent 0ed7e01bc7
commit 60f0cb8f2f

View File

@ -8,8 +8,8 @@ const lib = require('../index.js');
const dir = './tmp/'; const dir = './tmp/';
fs.readdir(dir).then(files => { fs.readdir(dir).then(files => {
// files.map(fileName => { const tt0 = Date.now();
async.eachSeries(files, (fileName, callback) => { async.eachLimit(files, 2, (fileName, callback) => {
let len = 0; let len = 0;
let chunks = 0; let chunks = 0;
let goodChunks = 0; let goodChunks = 0;
@ -35,5 +35,7 @@ fs.readdir(dir).then(files => {
); );
callback(); callback();
}); });
}, () => {
console.log('Total time: ' + (Date.now() - tt0) / 1000 + 's');
}); });
}); });