got.stream() not compatible with continue-stream

[techniq]

I attempted to use got.stream() with continue-stream to stream multiple pages of API requests into a single stream but it appears to not work. The first page will pull down, but additional calls will not work. Here's is the snippet I'm using for testing (pulled from their README). It works fine with the request library's stream that the example uses.

var continueStream = require('continue-stream')
var request = require('request')
var got = require('got')
var pumpify = require('pumpify')
var JSONStream = require('JSONStream')

var page = 1

function next(callback, previousStream) {
  if (page >= 4) return callback()

  /*
  var req = request({
    url: 'https://api.github.com/repos/joyent/node/events?page=' + (page++),
    headers: {'user-agent': 'pug'}
  })
  */
  var req = got.stream('https://api.github.com/repos/joyent/node/events?page=' + (page++), {
    headers: {'user-agent': 'pug'}
  })

  var stream = pumpify.obj(req, JSONStream.parse('*'))

  callback(null, stream)
}

continueStream.obj(next)
  .on('data', function(data) {
    console.log(data);
  })

[floatdrop]

@techniq seems like problem on the combine-stream side. I can recommend multistream as replacement:

var MultiStream = require('multistream')
var got = require('got')

var count = 0;
function factory (cb) {
  if (count > 3) return cb(null, null)
  count++
  setTimeout(function () {
    cb(null, got.stream('https://www.random.org/integers/?num='+count+'&min=1&max=6&col=1&base=10&format=plain&rnd=new'))
  }, 100)
}

MultiStream(factory).pipe(process.stdout);

[techniq]

@floatdrop Perfect, thanks