WEBDIENSTE/langgraph
1
0
Fork 0
mirror of https://github.com/langchain-ai/langgraph.git synced 2026-09-06 17:57:49 +02:00
Code Issues Packages Projects Releases Wiki Activity

Cleanup

Browse Source
This commit is contained in:
Tat Dat Duong
2025-02-12 15:55:10 -08:00
parent 7db81d72dc
commit da1fae0c72
1 changed files with 8 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libs/sdk-js/src/utils/sse.ts
+8 -24
View File
@@ -1,10 +1,3 @@
const mergeArrays = (a: ArrayLike<number>, b: ArrayLike<number>) => {
const mergedArray = new Uint8Array(a.length + b.length);
mergedArray.set(a);
mergedArray.set(b, a.length);
return mergedArray;
};
const CR = "\r".charCodeAt(0);
const LF = "\n".charCodeAt(0);
const NULL = "\0".charCodeAt(0);
@@ -30,7 +23,7 @@ export class BytesLineDecoder extends TransformStream<Uint8Array, Uint8Array> {
// Handle trailing CR from previous chunk
if (trailingCr) {
text = mergeArrays([CR], text);
text = joinArrays([[CR], text]);
trailingCr = false;
}
@@ -74,9 +67,7 @@ export class BytesLineDecoder extends TransformStream<Uint8Array, Uint8Array> {
if (buffer.length) {
// Include existing buffer in first line
buffer.push(lines[0]);
lines[0] = joinArrays(buffer);
buffer = [];
}
@@ -169,24 +160,17 @@ export class SSEDecoder extends TransformStream<Uint8Array, StreamPart> {
}
}
function decodeArraysToJson(decoder: TextDecoder, arrays: Uint8Array[]) {
const totalLength = arrays.reduce((acc, curr) => acc + curr.length, 0);
function joinArrays(data: ArrayLike<number>[]) {
const totalLength = data.reduce((acc, curr) => acc + curr.length, 0);
let merged = new Uint8Array(totalLength);
let offset = 0;
for (const c of arrays) {
merged.set(c, offset);
offset += c.length;
}
return JSON.parse(decoder.decode(merged));
}
function joinArrays(arrays: Uint8Array[]) {
const totalLength = arrays.reduce((acc, curr) => acc + curr.length, 0);
let merged = new Uint8Array(totalLength);
let offset = 0;
for (const c of arrays) {
for (const c of data) {
merged.set(c, offset);
offset += c.length;
}
return merged;
}
function decodeArraysToJson(decoder: TextDecoder, data: ArrayLike<number>[]) {
return JSON.parse(decoder.decode(joinArrays(data)));
}