Stream reply with Hapi

handler.js

    let valve = new Throtl.Valve({
      limit: 20,
      objectMode: true
    });

    reply(null, usersController
      .readStream()
      .pipe(valve)
      .pipe(through.obj(function (user, enc, next) {
        individualController
          .readIndividual(user._id)
          .then((individual) => {
            user.foo = individual.foo;
            let line = processUser(user);
            this.push(line + '\n');
            next();
          })
          .catch(debug);
      }))
      .pipe(through(function(line, enc, next) {
        // this is necessary to convert the object stream to a regular stream
        debug('line: ', line);
        this.push(line);
        next();
      }))).type('text/plain');