http streaming with hapi

server.js

'use strict';

import Stream from 'stream';
import config from 'config';
import Hapi from 'hapi';

let server = new Hapi.Server(config.server);

server.connection(config.connection);

server.route({
  method: 'get',
  path: '/',
  handler: (request, reply) => {
    let stream = new Stream.Transform();
    let i = setInterval(() => {
      stream.push(JSON.stringify({ foo: 'bar' }) + '\n');
    }, 100);
    setTimeout(() => {
      clearInterval(i);
      stream.push(null);
      console.log('ending stream');
    }, 5000);
    console.log('starting stream');
    reply(stream);
  }
});

server.start((err) => {
  if (err) throw new Error(err);
});