Spaces:
Runtime error
Runtime error
File size: 601 Bytes
4454f44 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 |
import asyncio
import websockets
USERS = set()
async def addUser(websocket):
USERS.add(websocket)
async def removeUser(websocket):
USERS.remove(websocket)
async def socket(websocket, path):
await addUser(websocket)
try:
while True:
message = await websocket.recv()
await asyncio.wait([user.send(message) for user in USERS])
finally:
await removeUser(websocket)
start_server = websockets.serve(socket, '0.0.0.0', 7860)
asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()
|