Fix memory from leaking

nodejs/node#6673
devit-tel · Aug 26, 2020 · 87da2de · 87da2de
1 parent a8fd6b1
commit 87da2de
Showing 1 changed file with 12 additions and 12 deletions.
diff --git a/src/event.ts b/src/event.ts
@@ -23,18 +23,18 @@ const retryBulkCreate = async (
 };
 
 export const executor = async () => {
-  try {
-    const events: IAllEventWithId[] = await poll(consumerEventClient, 200);
-    if (events.length) {
-      await retryBulkCreate(events, Number.MAX_VALUE, 10000);
-      console.log(`Inserted ${events.length} rows`);
-      consumerEventClient.commit();
+  while (true) {
+    try {
+      const events: IAllEventWithId[] = await poll(consumerEventClient, 200);
+      if (events.length) {
+        await retryBulkCreate(events, Number.MAX_VALUE, 10000);
+        console.log(`Inserted ${events.length} rows`);
+        consumerEventClient.commit();
+      }
+    } catch (error) {
+      // Handle error here
+      console.warn(error);
+      await sleep(1000);
     }
-  } catch (error) {
-    // Handle error here
-    console.warn(error);
-    await sleep(1000);
-  } finally {
-    setImmediate(executor);
   }
 };