|
@@ -70,13 +70,11 @@ export function getChatResponse({
|
|
|
};
|
|
|
|
|
|
ctrl.signal.addEventListener("abort", (e) => {
|
|
|
- // FIXME
|
|
|
- // if (e?.target?.reason?.message) {
|
|
|
- // error = e.target.reason
|
|
|
- // } else {
|
|
|
- // done = true
|
|
|
- // }
|
|
|
- done = true;
|
|
|
+ if (e?.target?.reason) {
|
|
|
+ error = new Error(e.target.reason);
|
|
|
+ } else {
|
|
|
+ done = true;
|
|
|
+ }
|
|
|
resolveQueuePromise();
|
|
|
eventSource.close();
|
|
|
});
|
|
@@ -95,8 +93,7 @@ export function getChatResponse({
|
|
|
}
|
|
|
// every looping stream, we wait for 10s
|
|
|
timer = setTimeout(() => {
|
|
|
- error = new Error("SSE timeout aborted.");
|
|
|
- ctrl.abort();
|
|
|
+ ctrl.abort("SSE timeout aborted.");
|
|
|
}, 10000);
|
|
|
if (queue.length > 0) {
|
|
|
yield queue.shift();
|