fix close but scheduler shutdowned

permitio · Dec 4, 2023 · 161ebda · 161ebda
1 parent 080144b
commit 161ebda
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/fastapi_websocket_rpc/websocket_rpc_client.py b/fastapi_websocket_rpc/websocket_rpc_client.py
@@ -56,7 +56,8 @@ async def recv(self):
     async def close(self, code: int = 1000):
         if self._websocket is not None:
             # Case opened, we have something to close.
-            await self._websocket.close(code)
+            #await asyncio.get_event_loop().run_in_executor(None, self._websocket.close,code)
+            self._websocket.close(code)
 
     async def handle_exception(self, exception: Exception):
         try: