| var fs = require ('fs'); |
| var net = require('net'); |
| var join = require('path').join; |
| var file = join(__dirname, 'fixtures','all_npm.json'); |
| var JSONStream = require('../'); |
| |
| |
| var server = net.createServer(function(client) { |
| var parser = JSONStream.parse([]); |
| parser.on('end', function() { |
| console.log('close') |
| console.error('PASSED'); |
| server.close(); |
| }); |
| client.pipe(parser); |
| var n = 4 |
| client.on('data', function () { |
| if(--n) return |
| client.end(); |
| }) |
| }); |
| server.listen(9999); |
| |
| |
| var client = net.connect({ port : 9999 }, function() { |
| fs.createReadStream(file).pipe(client).on('data', console.log) //.resume(); |
| }); |