| var fs = require ('fs'); |
| var net = require('net'); |
| var join = require('path').join; |
| var file = join(__dirname, 'fixtures','all_npm.json'); |
| var it = require('it-is'); |
| var JSONStream = require('../'); |
| |
| var str = fs.readFileSync(file); |
| |
| var server = net.createServer(function(client) { |
| var root_calls = 0; |
| var data_calls = 0; |
| var parser = JSONStream.parse(); |
| parser.on('root', function(root, count) { |
| ++ root_calls; |
| it(root_calls).notEqual(2); |
| }); |
| |
| parser.on('error', function(err) { |
| console.log(err); |
| server.close(); |
| }); |
| |
| parser.on('end', function() { |
| console.log('END'); |
| server.close(); |
| }); |
| client.pipe(parser); |
| }); |
| server.listen(9999); |
| |
| var client = net.connect({ port : 9999 }, function() { |
| var msgs = str + '}'; |
| client.end(msgs); |
| }); |