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