fix close but scheduler shutdowned

permitio · Dec 4, 2023 · bd4eb71 · bd4eb71
1 parent 161ebda
commit bd4eb71
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/fastapi_websocket_rpc/websocket_rpc_client.py b/fastapi_websocket_rpc/websocket_rpc_client.py
@@ -56,7 +56,6 @@ 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 asyncio.get_event_loop().run_in_executor(None, self._websocket.close,code)
             self._websocket.close(code)
 
     async def handle_exception(self, exception: Exception):
@@ -126,7 +125,7 @@ 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)
+            self._websocket.close(code)
 
     async def handle_exception(self, exception: Exception):
         try: