const http = require('http');
const stream = require('stream');

class ToJSON extends stream.Transform {
  writableObjectMode = true;

  _transform(chunk, encoding, done) {
    this.push(JSON.stringify(chunk)  + ',');
    done();
  }
}

http.createServer((request, response) => {
  response.writeHead(200, {
    'Content-Type': 'application/json',
    'Transfer-Encoding': 'chunked'
  })

  const data = [{ a: 1 }, { b: 2 }, { c: 3 }, { d: 4 }, { e: 5 }];
  const readable = stream.Readable.from(data, { objectMode: true });
  readable
    .pipe(new ToJSON({ objectMode: true }))
    .pipe(response);
}).listen(8080);

/*
{
    "a": 1
},
{
    "b": 2
},
{
    "c": 3
},
{
    "d": 4
},
{
    "e": 5
},
*/

[{
    "a": 1
},
{
    "b": 2
},
{
    "c": 3
},
{
    "d": 4
},
{
    "e": 5
}]