From 34970df58cf88b7571116d6581dd60ff1e6a5681 Mon Sep 17 00:00:00 2001
From: Neko <neko@ayaka.moe>
Date: Sat, 18 Jan 2025 10:54:00 +0800
Subject: [PATCH] fix(stream-text): incorrectly handled errors (#31)

Co-authored-by: iseki <admin@iseki.space>
---
 packages/stream-text/src/index.ts | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/packages/stream-text/src/index.ts b/packages/stream-text/src/index.ts
index 38e976b6..544ce8c4 100644
--- 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