Sha256: f264545e2fb52741b9b290886282ba4d6c9761f1f6c0418b477de9111fdee0a4
Contents?: true
Size: 679 Bytes
Versions: 13
Compression:
Stored size: 679 Bytes
Contents
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();
});
Version data entries
13 entries across 10 versions & 4 rubygems