(ws)
| 12 | |
| 13 | |
| 14 | async def receive_message(ws): |
| 15 | # while True: |
| 16 | # try: |
| 17 | # message = await ws.recv() |
| 18 | # print("Received: ", message) |
| 19 | # if message.data == b"Message 20": |
| 20 | # print("Closing connection...") |
| 21 | # break |
| 22 | # except asyncio.CancelledError: |
| 23 | # break |
| 24 | # or |
| 25 | async for message in ws: |
| 26 | print("Received: ", message) |
| 27 | if message.data == b"Message 20": |
| 28 | print("Closing connection...") |
| 29 | break |
| 30 | |
| 31 | |
| 32 | async def main(): |