1var fs = require ('fs'); 2var net = require('net'); 3var join = require('path').join; 4var file = join(__dirname, 'fixtures','all_npm.json'); 5var JSONStream = require('../'); 6 7 8var server = net.createServer(function(client) { 9 var parser = JSONStream.parse([]); 10 parser.on('end', function() { 11 console.log('close') 12 console.error('PASSED'); 13 server.close(); 14 }); 15 client.pipe(parser); 16 var n = 4 17 client.on('data', function () { 18 if(--n) return 19 client.end(); 20 }) 21}); 22server.listen(9999); 23 24 25var client = net.connect({ port : 9999 }, function() { 26 fs.createReadStream(file).pipe(client).on('data', console.log) //.resume(); 27}); 28