dev: Fix verbose stream closure

TheThingsNetwork · Dec 12, 2023 · c4164c6 · c4164c6
1 parent 30dc2f1
commit c4164c6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdk/js/src/api/stream/subscribeToWebSocketStream.js b/sdk/js/src/api/stream/subscribeToWebSocketStream.js
@@ -20,6 +20,7 @@ import { notify, EVENTS, MESSAGE_TYPES } from './shared'
 const wsInstances = {}
 let subscriptions = {}
 const initialListeners = Object.values(EVENTS).reduce((acc, curr) => ({ ...acc, [curr]: {} }), {})
+let closeRequested = false
 
 /**
  * Opens a new stream.
@@ -68,7 +69,6 @@ export default async (
     type: MESSAGE_TYPES.UNSUBSCRIBE,
     id: subscriptionId,
   })
-  let closeRequested = false
   const url = baseUrl + endpoint
 
   await Promise.race([