Simplify RPC watchWorker (#3394)

GMOD · Dec 13, 2022 · 3151648 · 3151648
1 parent 6e018ea
commit 3151648
Showing 1 changed file with 7 additions and 16 deletions.
diff --git a/packages/core/rpc/BaseRpcDriver.ts b/packages/core/rpc/BaseRpcDriver.ts
@@ -43,22 +43,13 @@ export async function watchWorker(
   rpcDriverClassName: string,
 ) {
   // after first ping succeeds, apply wait for timeout
-  return new Promise((_resolve, reject) => {
-    function delay() {
-      setTimeout(async () => {
-        try {
-          await worker.call('ping', [], {
-            timeout: pingTime * 2,
-            rpcDriverClassName,
-          })
-          delay()
-        } catch (e) {
-          reject(e)
-        }
-      }, pingTime)
-    }
-    delay()
-  })
+  while (true) {
+    await worker.call('ping', [], {
+      timeout: pingTime * 2,
+      rpcDriverClassName,
+    })
+    await new Promise(resolve => setTimeout(resolve, pingTime))
+  }
 }
 
 function detectHardwareConcurrency() {