| var fs = require ('fs') | |
| , join = require('path').join | |
| , file = join(__dirname, 'fixtures','depth.json') | |
| , JSONStream = require('../') | |
| , it = require('it-is') | |
| var expected = JSON.parse(fs.readFileSync(file)) | |
| , parser = JSONStream.parse(['docs', {recurse: true}, 'value']) | |
| , 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(5) | |
| for (var i = 0 ; i < 5 ; i++) | |
| it(parsed[i]).deepEqual(i) | |
| console.error('PASSED') | |
| }) |