すべてのストリームが終了するのを待ちます - ファイルのディレクトリをストリームします

Question

私は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); 
} 

Answer 1

一つの方法は、その後、Promise.all()を利用し、各アップロードのPromiseタスクを生成することです。

コードは次のようになり、あなたは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.'); }); 

Answer 2

は