mirror of
https://github.com/comfyanonymous/ComfyUI.git
synced 2026-05-10 09:12:31 +08:00
.
This commit is contained in:
parent
448fd67989
commit
b1677a80f3
@ -23,17 +23,15 @@ class ComfyApi extends EventTarget {
|
|||||||
this.dispatchEvent(new CustomEvent("status", { detail: null }));
|
this.dispatchEvent(new CustomEvent("status", { detail: null }));
|
||||||
|
|
||||||
}
|
}
|
||||||
}, 1000);
|
}, 2000);
|
||||||
}
|
}
|
||||||
|
|
||||||
#pollMessageQueue() {
|
#pollMessageQueue() {
|
||||||
let lastMessage = -1;
|
let lastMessage = -1;
|
||||||
setInterval(async () => {
|
setInterval(async () => {
|
||||||
const poll_messages = await (await fetch("/poll_messages")).json();
|
const poll_messages = await (await fetch("/poll_messages")).json();
|
||||||
if(poll_messages.length === 0) return;
|
poll_messages.forEach(msg => {
|
||||||
if(lastMessage === -1) lastMessage = poll_messages.length - 2;
|
if(lastMessage >= msg.poll_id) return;
|
||||||
for(let i = lastMessage + 1; i<poll_messages.length; i++) {
|
|
||||||
const msg = poll_messages[i];
|
|
||||||
console.log('MSG', msg);
|
console.log('MSG', msg);
|
||||||
switch (msg.type) {
|
switch (msg.type) {
|
||||||
case "status":
|
case "status":
|
||||||
@ -50,8 +48,8 @@ class ComfyApi extends EventTarget {
|
|||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
lastMessage = i;
|
lastMessage = i;
|
||||||
}
|
});
|
||||||
}, 1000)
|
}, 2000)
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user