node_modules/JSONStream/test/destroy_missing.js

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();

});