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 datas = {} var server = net.createServer(function(client) { var data_calls = 0; var parser = JSONStream.parse(['rows', true, 'key']); parser.on('data', function(data) { ++ data_calls; datas[data] = (datas[data] || 0) + 1 it(data).typeof('string') }); parser.on('end', function() { console.log('END') var min = Infinity for (var d in datas) min = min > datas[d] ? datas[d] : min it(min).equal(3); server.close(); }); client.pipe(parser); }); server.listen(9999); var client = net.connect({ port : 9999 }, function() { var msgs = str + ' ' + str + '\n\n' + str client.end(msgs); });
Name | Type | Size | Permission | Actions |
---|---|---|---|---|
fixtures | Folder | 0755 |
|
|
bool.js | File | 921 B | 0644 |
|
browser.js | File | 482 B | 0644 |
|
destroy_missing.js | File | 679 B | 0644 |
|
doubledot1.js | File | 685 B | 0644 |
|
doubledot2.js | File | 754 B | 0644 |
|
empty.js | File | 1023 B | 0644 |
|
error_contents.js | File | 865 B | 0644 |
|
fn.js | File | 785 B | 0644 |
|
gen.js | File | 4.14 KB | 0644 |
|
header_footer.js | File | 1.09 KB | 0644 |
|
issues.js | File | 647 B | 0644 |
|
keys.js | File | 2.57 KB | 0644 |
|
map.js | File | 767 B | 0644 |
|
multiple_objects.js | File | 932 B | 0644 |
|
multiple_objects_error.js | File | 694 B | 0644 |
|
null.js | File | 553 B | 0644 |
|
parsejson.js | File | 546 B | 0644 |
|
run.js | File | 443 B | 0644 |
|
stringify.js | File | 949 B | 0644 |
|
stringify_object.js | File | 1.1 KB | 0644 |
|
test.js | File | 748 B | 0644 |
|
test2.js | File | 556 B | 0644 |
|
two-ways.js | File | 920 B | 0644 |
|