| 1 | var 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 |
|
| 7 | var expected = JSON.parse(fs.readFileSync(file))
|
| 8 | , parser = JSONStream.parse('rows..rev')
|
| 9 | , called = 0
|
| 10 | , ended = false
|
| 11 | , parsed = []
|
| 12 |
|
| 13 | fs.createReadStream(file).pipe(parser)
|
| 14 |
|
| 15 | parser.on('data', function (data) {
|
| 16 | called ++
|
| 17 | parsed.push(data)
|
| 18 | })
|
| 19 |
|
| 20 | parser.on('end', function () {
|
| 21 | ended = true
|
| 22 | })
|
| 23 |
|
| 24 | process.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 | })
|