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

update text in websockets/falcon_server.py

pull/39/head
Ciro 2022-11-11 12:46:34 -03:00
rodzic eb91d7c90d
commit 5d6d61a15e
1 zmienionych plików z 1 dodań i 4 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

5
bench/websockets/falcon_server.py
Wyświetl plik

@ -6,14 +6,11 @@ clients = set([])
remaining_clients = 16 remaining_clients = 16
async def broadcast(message): async def broadcast(message):
# some clients got disconnected if we tried to to all async :/
# tasks = [ws.send_text(message) for ws in client] # tasks = [ws.send_text(message) for ws in client]
# return await asyncio.wait(tasks, return_when=ALL_COMPLETED) # return await asyncio.wait(tasks, return_when=ALL_COMPLETED)
for ws in clients: for ws in clients:
await ws.send_text(message) await ws.send_text(message)
# # for ws in clients:
# # tasks.append(ws.send_text(message))
# await asyncio.wait(tasks, return_when=ALL_COMPLETED)
class SomeResource: class SomeResource: