root/fusion
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(FN-1485): merge fusion/fn-1485

Browse Source
This commit is contained in:
gsxdsm
2026-04-13 15:02:21 -07:00
parent fd8da2c2c7
commit a8bc136ec4
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
packages/dashboard/app/api.ts
View File

@@ -4919,7 +4919,10 @@ export function streamChatResponse(
const lines = buffer.split("\n");
buffer = lines.pop() || "";
if (flushPendingEvent && buffer.length > 0) {
// Only push complete SSE lines (ending with \n) to lines for processing.
// Incomplete lines (no trailing \n) are intentionally left in the buffer
// to be continued by the next chunk or properly handled at stream end.
if (flushPendingEvent && buffer.length > 0 && buffer.endsWith("\n")) {
lines.push(buffer);
buffer = "";
}
@@ -4940,7 +4943,9 @@ export function streamChatResponse(
}
}
if (flushPendingEvent) {
// Flush any pending event/data at stream end.
// Only dispatch if we have both a valid event type and accumulated data.
if (flushPendingEvent && currentEvent && currentDataLines.length > 0) {
const trailingData = currentDataLines.join("\n");
dispatchEvent(currentEvent, trailingData);
currentEvent = "";