mirror
/
socketify.py
kopia lustrzana https://github.com/cirospaciari/socketify.py
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

fix libuv blocking without need

pull/75/head
Ciro 2023-03-10 13:08:34 -03:00
rodzic f006601588
commit 7adfb90ccf
1 zmienionych plików z 3 dodań i 1 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

4
src/socketify/loop.py
Wyświetl plik

@ -34,6 +34,7 @@ class Loop:
asyncio.set_event_loop(self.loop) asyncio.set_event_loop(self.loop)
self.uv_loop = UVLoop() self.uv_loop = UVLoop()
self.call_uv_next = False
if hasattr(exception_handler, "__call__"): if hasattr(exception_handler, "__call__"):
self.exception_handler = exception_handler self.exception_handler = exception_handler
@ -75,9 +76,10 @@ class Loop:
def create_future(self): def create_future(self):
return self.loop.create_future() return self.loop.create_future()
def _keep_alive(self): def _keep_alive(self):
if self.started: if self.started:
self.uv_loop.run_once() self.uv_loop.run_nowait()
self.loop.call_soon(self._keep_alive) self.loop.call_soon(self._keep_alive)
def create_task(self, *args, **kwargs): def create_task(self, *args, **kwargs):