mirror of
https://github.com/comfyanonymous/ComfyUI.git
synced 2026-05-10 01:02:56 +08:00
.
This commit is contained in:
parent
8346dae155
commit
3530a9532c
@ -287,6 +287,7 @@ class PromptServer():
|
||||
|
||||
async def send(self, event, data, sid=None):
|
||||
message = {"type": event, "data": data}
|
||||
self.poll_messages.append({"type": event, "data": data, "sid": sid, "poll_id": poll_id++})
|
||||
|
||||
if isinstance(message, str) == False:
|
||||
message = json.dumps(message)
|
||||
@ -298,7 +299,6 @@ class PromptServer():
|
||||
await self.sockets[sid].send_str(message)
|
||||
|
||||
def send_sync(self, event, data, sid=None):
|
||||
self.poll_messages.append({"type": event, "data": data, "sid": sid, "poll_id": poll_id++})
|
||||
self.loop.call_soon_threadsafe(
|
||||
self.messages.put_nowait, (event, data, sid))
|
||||
|
||||
|
||||
Loading…
Reference in New Issue
Block a user