perf: stream

src/service/utils/openai.ts

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