summaryrefslogtreecommitdiff
path: root/deps/node/deps/npm/node_modules/JSONStream/test/destroy_missing.js
diff options
context:
space:
mode:
authorFlorian Dold <florian.dold@gmail.com>2019-04-03 15:43:32 +0200
committerFlorian Dold <florian.dold@gmail.com>2019-04-03 15:45:57 +0200
commit71e285b94c7edaa43aa8115965cf5a36b8e0f80a (patch)
tree7d4aa9d0d5aff686b106cd5da72ba77960c4af43 /deps/node/deps/npm/node_modules/JSONStream/test/destroy_missing.js
parent7dadf9356b4f3f4137ce982ea5bb960283116e9a (diff)
downloadakono-71e285b94c7edaa43aa8115965cf5a36b8e0f80a.tar.gz
akono-71e285b94c7edaa43aa8115965cf5a36b8e0f80a.tar.bz2
akono-71e285b94c7edaa43aa8115965cf5a36b8e0f80a.zip
Node.js v11.13.0
Diffstat (limited to 'deps/node/deps/npm/node_modules/JSONStream/test/destroy_missing.js')
-rw-r--r--deps/node/deps/npm/node_modules/JSONStream/test/destroy_missing.js27
1 files changed, 27 insertions, 0 deletions
diff --git a/deps/node/deps/npm/node_modules/JSONStream/test/destroy_missing.js b/deps/node/deps/npm/node_modules/JSONStream/test/destroy_missing.js
new file mode 100644
index 00000000..315fdc83
--- /dev/null
+++ b/deps/node/deps/npm/node_modules/JSONStream/test/destroy_missing.js
@@ -0,0 +1,27 @@
+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();
+});