From 71f65744810d84b9da7f79ae8c6c221dc645a677 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Serkan=20=C3=96zel?= Date: Mon, 3 Oct 2022 11:16:14 +0300 Subject: [PATCH] Fix leak in ReliableTopicListenerRunner.next (#1377) (#1379) --- src/proxy/topic/ReliableTopicListenerRunner.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/proxy/topic/ReliableTopicListenerRunner.ts b/src/proxy/topic/ReliableTopicListenerRunner.ts index 01506d225..331925930 100644 --- a/src/proxy/topic/ReliableTopicListenerRunner.ts +++ b/src/proxy/topic/ReliableTopicListenerRunner.ts @@ -90,7 +90,7 @@ export class ReliableTopicListenerRunner { }) .catch((err) => { if (this.handleInternalError(err)) { - this.next(); + setImmediate(this.next.bind(this)); } else { this.proxy.removeMessageListener(this.listenerId); }