等待所有流完成 - 流文件目錄

我使用client.upload在pkgcloud上傳文件的目錄。所有流完成後執行回調的最佳方式是什麼？是否有內置的方法來註冊每個流的「完成」事件並在全部觸發後執行回調？等待所有流完成 - 流文件目錄

var filesToUpload = fs.readdirSync("./local_path"); // will make this async 

for(let file of filesToUpload) { 
    var writeStream = client.upload({ 
     container: "mycontainer, 
     remote: file 
    }); 
    // seems like i should register finish events with something 
    writeStream.on("finish", registerThisWithSomething); 
    fs.createReadStream("./local_path/" + file).pipe(writeStream); 
}

來源

2016-05-14 berg

您可以使用async.js爲這種問題。您可以使用async.js提供的方法作爲'async.waterfall（）'。一個函數的結果將作爲回調參數傳遞給另一個函數。您應該查看它的文檔。 –

一種方式做到這一點，是生成每次上傳一個Promise任務，然後利用Promise.all()。

假設你正在使用ES6，代碼會是這個樣子：

const uploadTasks = filesToUpload.map((file) => new Promise((resolve, reject) => { 
    var writeStream = client.upload({ 
     container: "mycontainer, 
     remote: file 
    }); 
    // seems like i should register finish events with something 
    writeStream.on("finish", resolve); 
    fs.createReadStream("./local_path/" + file).pipe(writeStream); 
}); 

Promise.all(uploadTasks) 
    .then(() => { console.log('All uploads completed.'); });

來源

2016-05-14 17:33:51 JAM

謝謝你這個作品！ – berg

看看NodeDir，它具有類似的方法readFilesStream/promiseFiles等

來源

2018-02-10 12:05:33

等待所有流完成 - 流文件目錄

回答

相關問題