xkrs_manan/RODY
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ws

Browse Source
This commit is contained in:
JIAKUNHAO 2022-11-24 15:25:44 +08:00
parent 1804640fc3
commit a2df6f7df6
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
app/utils/websocket_tool.py
View File

@ -67,6 +67,7 @@ class WebsocketUtil:
# global active_connections_dist # global active_connections_dist
active_connections_dist = self.queue.get() active_connections_dist = self.queue.get()
self.queue.put(active_connections_dist) self.queue.put(active_connections_dist)
print(active_connections_dist)
for connection in active_connections_dist[id]: for connection in active_connections_dist[id]:
try: try:
connection.send(json.dumps(message, cls=MyEncoder, indent=4), ) connection.send(json.dumps(message, cls=MyEncoder, indent=4), )