| 123456789101112131415 |
- import asyncio, queue
- message_queue = asyncio.Queue()
- websocket_manager = None
- websocket = None
- # def sendSocketMessage(data):
- # payload = data
- # loop = asyncio.get_event_loop()
- # if websocket_manager == None:
- # loop.create_task(message_queue.put(payload))
- # else:
- # async def _do_send():
- # await websocket_manager.send_personal_message(payload, websocket_manager)
- # loop.create_task(_do_send())
- # print("\033[1;32;40m common===>sendSocketMessage \033[0m", data)
|
