1var fs = require ('fs') 2 , join = require('path').join 3 , file = join(__dirname, 'fixtures','all_npm.json') 4 , JSONStream = require('../') 5 , it = require('it-is') 6 7var expected = JSON.parse(fs.readFileSync(file)) 8 , parser = JSONStream.parse('rows..rev') 9 , called = 0 10 , ended = false 11 , parsed = [] 12 13fs.createReadStream(file).pipe(parser) 14 15parser.on('data', function (data) { 16 called ++ 17 parsed.push(data) 18}) 19 20parser.on('end', function () { 21 ended = true 22}) 23 24process.on('exit', function () { 25 it(called).equal(expected.rows.length) 26 for (var i = 0 ; i < expected.rows.length ; i++) 27 it(parsed[i]).deepEqual(expected.rows[i].value.rev) 28 console.error('PASSED') 29}) 30