WEBDIENSTE/langgraph
1
0
Fork 0
mirror of https://github.com/langchain-ai/langgraph.git synced 2026-09-07 18:27:52 +02:00
Code Issues Packages Projects Releases Wiki Activity

test

Browse Source
This commit is contained in:
Tat Dat Duong
2025-02-12 15:55:09 -08:00
parent b902db686d
commit 4ce387ee28
1 changed files with 14 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libs/sdk-js/src/utils/sse.ts
+14 -15
View File
@@ -44,26 +44,25 @@ export class BytesLineDecoder extends TransformStream<Uint8Array, Uint8Array> {
const trailingNewline = TRAILING_NEWLINE.includes(text.at(-1)!);
const lastIdx = text.length - 1;
const [lines] = text.reduce(
const { lines } = text.reduce(
(acc, cur, idx) => {
if (cur === CR) {
if (text[idx + 1] === LF) {
acc[0].push(text.subarray(acc[1], idx));
acc[1] = idx + 2;
} else {
acc[0].push(text.subarray(acc[1], idx));
acc[1] = idx + 1;
}
} else if (cur === LF && text[idx - 1] !== CR) {
acc[0].push(text.subarray(acc[1], idx));
acc[1] = idx + 1;
if (acc.from > idx) return acc;
if (cur === CR && text[idx + 1] === LF) {
acc.lines.push(text.subarray(acc.from, idx));
acc.from = idx + 2;
} else if (cur === CR || cur === LF) {
acc.lines.push(text.subarray(acc.from, idx));
acc.from = idx + 1;
}
if (idx === lastIdx && acc[1] < lastIdx) {
acc[0].push(text.subarray(acc[1]));
if (idx === lastIdx && acc.from < lastIdx) {
acc.lines.push(text.subarray(acc.from));
}
return acc;
},
[[], 0] as [Uint8Array[], number],
{ lines: [], from: 0 } as { lines: Uint8Array[]; from: number },
);
if (lines.length === 1 && !trailingNewline) {