From b11977bbacf6653f0ef7eb5a2c01cdcf0ba2c877 Mon Sep 17 00:00:00 2001
From: Leonardo Venturini <leovenbag@gmail.com>
Date: Thu, 7 Nov 2024 17:01:34 -0400
Subject: [PATCH] add timeout mechanism

---
 packages/mongo/observe_handle.ts | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/packages/mongo/observe_handle.ts b/packages/mongo/observe_handle.ts
index a18f213400..d084322a61 100644
--- a/packages/mongo/observe_handle.ts
+++ b/packages/mongo/observe_handle.ts
@@ -45,9 +45,16 @@ export class ObserveHandle {
     this.nonMutatingCallbacks = nonMutatingCallbacks;
 
     this.initialAddsSent = new Promise(resolve => {
-      return this.initialAddsSentResolver = () => {
+      const ready = () => {
         resolve();
         this.initialAddsSent = Promise.resolve();
+      }
+
+      const timeout = setTimeout(ready, 30000)
+
+      this.initialAddsSentResolver = () => {
+        ready();
+        clearTimeout(timeout);
       };
     });
   }