var JSONStream = require('../')
    , stream = require('stream')
    , it = require('it-is')
  
  var output = [ [], [] ]
  
  var parser1 = JSONStream.parse(['docs', /./])
  parser1.on('data', function(data) {
    output[0].push(data)
  })
  
  var parser2 = JSONStream.parse(['docs', /./])
  parser2.on('data', function(data) {
    output[1].push(data)
  })
  
  var pending = 2
  function onend () {
    if (--pending > 0) return
    it(output).deepEqual([
      [], [{hello: 'world'}]
    ])
    console.error('PASSED')
  }
  parser1.on('end', onend)
  parser2.on('end', onend)
  
  function makeReadableStream() {
    var readStream = new stream.Stream()
    readStream.readable = true
    readStream.write = function (data) { this.emit('data', data) }
    readStream.end = function (data) { this.emit('end') }
    return readStream
  }
  
  var emptyArray = makeReadableStream()
  emptyArray.pipe(parser1)
  emptyArray.write('{"docs":[]}')
  emptyArray.end()
  
  var objectArray = makeReadableStream()
  objectArray.pipe(parser2)
  objectArray.write('{"docs":[{"hello":"world"}]}')
  objectArray.end()