var fs = require ('fs')
    , join = require('path').join
    , file = join(__dirname, 'fixtures','all_npm.json')
    , JSONStream = require('../')
    , it = require('it-is')
  
  var expected = JSON.parse(fs.readFileSync(file))
    , parser = JSONStream.parse('rows..rev')
    , called = 0
    , ended = false
    , parsed = []
  
  fs.createReadStream(file).pipe(parser)
    
  parser.on('data', function (data) {
    called ++
    parsed.push(data)
  })
  
  parser.on('end', function () {
    ended = true
  })
  
  process.on('exit', function () {
    it(called).equal(expected.rows.length)
    for (var i = 0 ; i < expected.rows.length ; i++)
      it(parsed[i]).deepEqual(expected.rows[i].value.rev)
    console.error('PASSED')
  })