I need callbacks on _read

attempted-solution.js

var stream = require('stream');

var outer = 0, inner = 0;

var collectorStream = stream.Readable({
  highWaterMark: 1,
  objectMode: true,
  read: function() {
    var self = this;
    var id1 = outer++;
    setTimeout(function() {
      var id2 = inner++;
      setTimeout(function() {
        if(id2 === 10) return self.push(null);
        //Concat in here
        self.push({outer: id1, inner: id2});
      }, 100*Math.random())
    }, 50*Math.random())
  }
});

var fanoutStream = stream.Transform({
  readableObjectMode: true,
  writableObjectMode: true,
  allowHalfOpen: true,
  highWaterMark: 16,
  transform: function(itemSet, enc, cb) {
    for (var i = 0; i < 10; i++)
      this.push(itemSet);

    cb();
  }
});

collectorStream.pipe(fanoutStream).on('data', console.log.bind(console));

problem.js

var stream = require('stream');

var outer = 0, inner = 0;
var spaghettiStream = new stream.Readable({
  highWaterMark: 1,
  objectMode: true,
  read: function() {
    var self = this;
    var id1 = outer++;
    setTimeout(function() {
      var id2 = inner++;
      setTimeout(function() {
        for (var i = 0; i < 3; i++)
          self.push({hello: true, outer: id1, inner: id2, i: i});
      }, 50*Math.random());
    }, 100*Math.random());
  }
});

spaghettiStream.on('data', console.log.bind(console));