From c6a5f16336e4f1f741737cdb0708fb5bb1fb086f Mon Sep 17 00:00:00 2001
From: archer <545436317@qq.com>
Date: Wed, 26 Apr 2023 13:48:25 +0800
Subject: [PATCH] perf: stream

---
 src/service/utils/openai.ts | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/service/utils/openai.ts b/src/service/utils/openai.ts
index 9c0b7afa4..3fbd23bc1 100644
--- a/src/service/utils/openai.ts
+++ b/src/service/utils/openai.ts
@@ -146,13 +146,13 @@ export const gpt35StreamResponse = ({
 
       const decoder = new TextDecoder();
       try {
+        const parser = createParser(onParse);
         for await (const chunk of chatResponse.data as any) {
           if (stream.destroyed) {
             // 流被中断了，直接忽略后面的内容
             break;
           }
-          const parser = createParser(onParse);
-          parser.feed(decoder.decode(chunk));
+          parser.feed(decoder.decode(chunk, { stream: true }));
         }
       } catch (error) {
         console.log('pipe error', error);