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);