fix(__aexit__): replace fail_connection with close (#1471)

sammchardy · Nov 13, 2024 · 1867c30 · 1867c30
1 parent bc74c57
commit 1867c30
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/binance/streams.py b/binance/streams.py
@@ -79,7 +79,8 @@ async def __aexit__(self, exc_type, exc_val, exc_tb):
             await self._exit_coro(self._path)
         self.ws_state = WSListenerState.EXITING
         if self.ws:
-            self.ws.fail_connection()
+            # self.ws.fail_connection()
+            await self.ws.close()
         if self._conn and hasattr(self._conn, "protocol"):
             await self._conn.__aexit__(exc_type, exc_val, exc_tb)
         self.ws = None