| 123456789101112131415161718192021222324252627282930313233343536373839 |
- var fs = require ('fs')
- , join = require('path').join
- , file = join(__dirname, 'fixtures','all_npm.json')
- , JSONStream = require('../')
- , it = require('it-is')
- function fn (s) {
- return !isNaN(parseInt(s, 10))
- }
- var expected = JSON.parse(fs.readFileSync(file))
- , parser = JSONStream.parse(['rows', fn])
- , called = 0
- , ended = false
- , parsed = []
- fs.createReadStream(file).pipe(parser)
-
- parser.on('data', function (data) {
- called ++
- it.has({
- id: it.typeof('string'),
- value: {rev: it.typeof('string')},
- key:it.typeof('string')
- })
- parsed.push(data)
- })
- parser.on('end', function () {
- ended = true
- })
- process.on('exit', function () {
- it(called).equal(expected.rows.length)
- it(parsed).deepEqual(expected.rows)
- console.error('PASSED')
- })
|
