Transforming objects in a stream

transform-stream

import { Transform } from 'stream'
import inputStream from 'input-stream'
import outputStream from 'output-stream'

inputStream('input.csv')
  .pipe(
    Transform({
      readableObjectMode: true,
      writableObjectMode: true,
      transform: (chunk, encoding, callback) => {
        console.log(chunk)
        callback(null, chunk)
      },
    })
  )
  .pipe(outputStream('output.ndjson'))
  .on('finish', () => {
    console.log('finished')
  })