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

fix async wrappers

pull/129/head v0.0.23
cirospaciari 2023-07-05 11:49:37 -03:00
rodzic b3e7b494ab
commit c96c243fd2
3 zmienionych plików z 8 dodań i 8 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

2
pyproject.toml
Wyświetl plik

@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
[project] [project]
name = "socketify" name = "socketify"
version = "0.0.22" version = "0.0.23"
authors = [ authors = [
{ name="Ciro Spaciari", email="ciro.spaciari@gmail.com" }, { name="Ciro Spaciari", email="ciro.spaciari@gmail.com" },
] ]

2
setup.py
Wyświetl plik

@ -58,7 +58,7 @@ with open("README.md", "r", encoding="utf-8") as fh:
setuptools.setup( setuptools.setup(
name="socketify", name="socketify",
version="0.0.22", version="0.0.23",
platforms=["any"], platforms=["any"],
author="Ciro Spaciari", author="Ciro Spaciari",
author_email="ciro.spaciari@gmail.com", author_email="ciro.spaciari@gmail.com",

12
src/socketify/socketify.py
Wyświetl plik

@ -668,7 +668,7 @@ def uws_websocket_factory_close_handler(ws, code, message, length, user_data):
if inspect.iscoroutinefunction(handler): if inspect.iscoroutinefunction(handler):
async def wrapper(app, instances, handler, ws, data, code, dispose): async def wrapper(app, instances, handler, ws, code, data, dispose):
try: try:
return await handler(ws, code, data) return await handler(ws, code, data)
finally: finally:
@ -679,7 +679,7 @@ def uws_websocket_factory_close_handler(ws, code, message, length, user_data):
app._ws_factory.dispose(instances) app._ws_factory.dispose(instances)
app.run_async( app.run_async(
wrapper(app, instances, handler, ws, data, int(code), dispose) wrapper(app, instances, handler, ws, int(code), data, dispose)
) )
else: else:
handler(ws, int(code), data) handler(ws, int(code), data)
@ -720,7 +720,7 @@ def uws_websocket_close_handler_with_extension(ws, code, message, length, user_d
if inspect.iscoroutinefunction(handler): if inspect.iscoroutinefunction(handler):
async def wrapper(app, handler, ws, data, code, dispose): async def wrapper(app, handler, ws, code, data):
try: try:
return await handler(ws, code, data) return await handler(ws, code, data)
finally: finally:
@ -728,7 +728,7 @@ def uws_websocket_close_handler_with_extension(ws, code, message, length, user_d
if key is not None: if key is not None:
app._socket_refs.pop(key, None) app._socket_refs.pop(key, None)
app.run_async(wrapper(app, handler, ws, data, int(code))) app.run_async(wrapper(app, handler, ws, int(code), data))
else: else:
handler(ws, int(code), data) handler(ws, int(code), data)
key = ws.get_user_data_uuid() key = ws.get_user_data_uuid()
@ -762,7 +762,7 @@ def uws_websocket_close_handler(ws, code, message, length, user_data):
if inspect.iscoroutinefunction(handler): if inspect.iscoroutinefunction(handler):
async def wrapper(app, handler, ws, data, code, dispose): async def wrapper(app, handler, ws, code, data):
try: try:
return await handler(ws, code, data) return await handler(ws, code, data)
finally: finally:
@ -770,7 +770,7 @@ def uws_websocket_close_handler(ws, code, message, length, user_data):
if key is not None: if key is not None:
app._socket_refs.pop(key, None) app._socket_refs.pop(key, None)
app.run_async(wrapper(app, handler, ws, data, int(code))) app.run_async(wrapper(app, handler, ws, int(code), data))
else: else:
handler(ws, int(code), data) handler(ws, int(code), data)
key = ws.get_user_data_uuid() key = ws.get_user_data_uuid()