stream: fix removeAllListeners() for Stream.Readable

Fixes: #20923 PR-URL: #20924 Refs: #20923 Reviewed-By: Anatoli Papirovski <[email protected]> Reviewed-By: Luigi Pinca <[email protected]> Reviewed-By: Matteo Collina <[email protected]>
nodejs · May 29, 2018 · 8f52c3f · 8f52c3f
1 parent 5f9c01b
commit 8f52c3f
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 1 deletion.
diff --git a/lib/_stream_readable.js b/lib/_stream_readable.js
@@ -846,7 +846,7 @@ Readable.prototype.removeListener = function(ev, fn) {
 };
 
 Readable.prototype.removeAllListeners = function(ev) {
-  const res = Stream.prototype.removeAllListeners.call(this, ev);
+  const res = Stream.prototype.removeAllListeners.apply(this, arguments);
 
   if (ev === 'readable' || ev === undefined) {
     // We need to check if there is someone still listening to

diff --git a/test/parallel/test-stream-readable-event.js b/test/parallel/test-stream-readable-event.js
@@ -113,3 +113,16 @@ const Readable = require('stream').Readable;
     assert.deepStrictEqual(result, expected);
   }));
 }
+
+{
+  // #20923
+  const r = new Readable();
+  r._read = function() {
+    // actually doing thing here
+  };
+  r.on('data', function() {});
+
+  r.removeAllListeners();
+
+  assert.strictEqual(r.eventNames().length, 0);
+}