mirror of
https://github.com/thangisme/notes.git
synced 2024-07-01 14:45:34 +00:00
30 lines
667 B
JavaScript
30 lines
667 B
JavaScript
|
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')
|
||
|
|
})
|