Fix leak in ReliableTopicListenerRunner.next (#1377) (#1382)

hazelcast · Oct 3, 2022 · b4dbfa8 · b4dbfa8
1 parent f8f0526
commit b4dbfa8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/proxy/topic/ReliableTopicListenerRunner.ts b/src/proxy/topic/ReliableTopicListenerRunner.ts
@@ -90,7 +90,7 @@ export class ReliableTopicListenerRunner<E> {
             })
             .catch((err) => {
                 if (this.handleInternalError(err)) {
-                    this.next();
+                    setImmediate(this.next.bind(this));
                 } else {
                     this.proxy.removeMessageListener(this.listenerId);
                 }