fix(stream-text): incorrectly handled errors (#31)

Co-authored-by: iseki <admin@iseki.space>
moeru-ai · Jan 18, 2025 · 34970df · 34970df
1 parent 90d0db0
commit 34970df
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/packages/stream-text/src/index.ts b/packages/stream-text/src/index.ts
@@ -75,13 +75,13 @@ export const streamText = async (options: StreamTextOptions): Promise<StreamText
           continue
         }
 
-        if (line.startsWith(chunkErrorPrefix)) {
+        const lineWithoutPrefix = line.slice(chunkHeaderPrefix.length)
+        if (lineWithoutPrefix.startsWith(chunkErrorPrefix)) {
           // About controller error: https://developer.mozilla.org/en-US/docs/Web/API/TransformStreamDefaultController/error
-          controller.error(new Error(`Error from server: ${line}`))
+          controller.error(new Error(`Error from server: ${lineWithoutPrefix}`))
           break
         }
 
-        const lineWithoutPrefix = line.slice(chunkHeaderPrefix.length)
         if (lineWithoutPrefix === '[DONE]') {
           controller.terminate()
           break