From 60288d070438dc8958cf502f1bf91025d9ef1519 Mon Sep 17 00:00:00 2001 From: SpaceEEC Date: Tue, 8 May 2018 11:57:12 +0200 Subject: [PATCH] fix(Collector): increase and decrease max listeners dynamically --- src/structures/MessageCollector.js | 2 ++ src/structures/ReactionCollector.js | 2 ++ 2 files changed, 4 insertions(+) diff --git a/src/structures/MessageCollector.js b/src/structures/MessageCollector.js index c0a51c813..1e93e911d 100644 --- a/src/structures/MessageCollector.js +++ b/src/structures/MessageCollector.js @@ -33,6 +33,7 @@ class MessageCollector extends Collector { */ this.received = 0; + this.client.setMaxListeners(this.client.getMaxListeners() + 1); this.client.on('message', this.listener); // For backwards compatibility (remove in v12) @@ -92,6 +93,7 @@ class MessageCollector extends Collector { cleanup() { this.removeListener('collect', this._reEmitter); this.client.removeListener('message', this.listener); + this.client.setMaxListeners(this.client.getMaxListeners() - 1); } } diff --git a/src/structures/ReactionCollector.js b/src/structures/ReactionCollector.js index ecdb37674..0be2d8920 100644 --- a/src/structures/ReactionCollector.js +++ b/src/structures/ReactionCollector.js @@ -39,6 +39,7 @@ class ReactionCollector extends Collector { */ this.total = 0; + this.client.setMaxListeners(this.client.getMaxListeners() + 1); this.client.on('messageReactionAdd', this.listener); } @@ -77,6 +78,7 @@ class ReactionCollector extends Collector { */ cleanup() { this.client.removeListener('messageReactionAdd', this.listener); + this.client.setMaxListeners(this.client.getMaxListeners() - 1); } }