Fix max listeners exceeded warning

nodeca · Mar 10, 2021 · a6da059 · a6da059
1 parent bcdd824
commit a6da059
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/stream.js b/stream.js
@@ -10,6 +10,9 @@ var pipeline    = require('stream').pipeline;
 module.exports = function probeStream(src, keepOpen) {
   var proxy = new PassThrough();
 
+  // increase max number of listeners to stop memory leak warning
+  proxy.setMaxListeners(Object.keys(parsers).length + 10);
+
   var result = new Promise(function (resolve, reject) {
     src.on('error', reject);
     proxy.on('error', reject);