Transforms a Json file and write the output back

stream-transform.js

const fs = require('fs');
const es = require('event-stream');
const JSONStream = require('JSONStream');

const inStream = fs.createReadStream('tests/fixtures/claims10k.json');
const outStream = fs.createWriteStream('tests/fixtures/claims10kPatched.json');

const map = es.mapSync((d) => {
  const email = `${d.debtorName.toLowerCase()}.${d.debtorLastName.toLowerCase()}@email.com`;
  return Object.assign({}, d, { email });
});

inStream
  .pipe(JSONStream.parse('*'))
  .pipe(map)
  .pipe(JSONStream.stringify())
  .pipe(outStream);
  // .pipe(process.stdout);