ws
This commit is contained in:
parent
844f673b0e
commit
7489a3e3c8
@ -23,7 +23,7 @@ class WebsocketUtil:
|
|||||||
|
|
||||||
def __init__(self):
|
def __init__(self):
|
||||||
# self.active_connections = multiprocessing.Manager().list()
|
# self.active_connections = multiprocessing.Manager().list()
|
||||||
self.active_connections_dist = {}
|
self.active_connections_dist = []
|
||||||
|
|
||||||
|
|
||||||
def connect(self, ws, id: str):
|
def connect(self, ws, id: str):
|
||||||
@ -35,7 +35,7 @@ class WebsocketUtil:
|
|||||||
ws_list.append(ws)
|
ws_list.append(ws)
|
||||||
else:
|
else:
|
||||||
ws_list = [ws, ]
|
ws_list = [ws, ]
|
||||||
write(id=id, ws=list)
|
write(id=id, ws=ws_list)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user