|
@@ -218,7 +218,9 @@ async def disconnect(sid):
|
|
def get_event_emitter(request_info):
|
|
def get_event_emitter(request_info):
|
|
async def __event_emitter__(event_data):
|
|
async def __event_emitter__(event_data):
|
|
user_id = request_info["user_id"]
|
|
user_id = request_info["user_id"]
|
|
- session_ids = USER_POOL.get(user_id, [])
|
|
|
|
|
|
+ session_ids = list(
|
|
|
|
+ set(USER_POOL.get(user_id, []) + [request_info["session_id"]])
|
|
|
|
+ )
|
|
|
|
|
|
for session_id in session_ids:
|
|
for session_id in session_ids:
|
|
await sio.emit(
|
|
await sio.emit(
|