chore: wait for ok for pendingReconnect

Signed-off-by: Case Wylie <[email protected]>
defenseunicorns · Nov 5, 2024 · 06b63d0 · 06b63d0
1 parent ab03054
commit 06b63d0
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/src/fluent/watch.ts b/src/fluent/watch.ts
@@ -437,11 +437,11 @@ export class Watcher<T extends GenericClass> {
       // Make the actual request
       const response = await legacyFetch(url, { ...opts });
 
-      // Reset the pending reconnect flag
-      this.#pendingReconnect = false;
-
       // If the request is successful, start listening for events
       if (response.ok) {
+        // Reset the pending reconnect flag
+        this.#pendingReconnect = false;
+
         this.#events.emit(WatchEvent.CONNECT, url.pathname);
 
         const { body } = response;
@@ -518,11 +518,11 @@ export class Watcher<T extends GenericClass> {
         dispatcher: Watcher.getHTTPSAgent(opts),
       });
 
-      // Reset the pending reconnect flag
-      this.#pendingReconnect = false;
-
       // If the request is successful, start listening for events
       if (response.ok) {
+        // Reset the pending reconnect flag
+        this.#pendingReconnect = false;
+
         this.#events.emit(WatchEvent.CONNECT, url.pathname);
 
         const { body } = response;