nodejs v12(LTS)におけるasync, awaitを用いたstream処理 - Qiita

const fs = require('fs'); const stream = require('stream'); const util = require('util'); const finished = util.promisify(stream.finished); const msleep = util.promisify(setTimeout); // streamを用いた場合の処理(全体終了部分のみのpromise化) const reader1 = async (rs) => { rs.on('data', (chunk) => { console.log(chunk); }); await finished(rs); // stream.finishedを使わない場合下記のようなpromiseを生成する // await new Promise((resolve, r

[hkj]

readline