https://repl.it/@lubien/promises-from-stream

foo.csv

1
2
3
4
5
6
7
8
9

stream-as-promise.js

function process () {
  return new Promise(resolve => {
    const lineReader = require('readline').createInterface({
      input: require('fs').createReadStream('foo.csv')
    })

    const promises = []

    lineReader.on('line', line => {
      promises.push(timeout(1000, line))
    })

    lineReader.on('close', () => {
      resolve(Promise.all(promises))
    })
  })
}

function timeout(n, result) {
  return new Promise(resolve => setTimeout(() => resolve(result), n))
}

async function main () {
  const data = await process()
  console.log(data)
}

main()