|
@@ -1,7 +1,7 @@
|
|
|
import { bluebookAiAgent } from "@/xiaolanbenlib/api/index";
|
|
import { bluebookAiAgent } from "@/xiaolanbenlib/api/index";
|
|
|
import Taro from "@tarojs/taro";
|
|
import Taro from "@tarojs/taro";
|
|
|
import { getSimpleHeader } from "@/xiaolanbenlib/module/axios.js";
|
|
import { getSimpleHeader } from "@/xiaolanbenlib/module/axios.js";
|
|
|
-import JsonChunkParser, { ICompleteCallback } from "@/utils/jsonChunkParser";
|
|
|
|
|
|
|
+import ChunkParser, { ICompleteCallback } from "@/utils/ChunkParser";
|
|
|
import request from "@/xiaolanbenlib/module/axios.js";
|
|
import request from "@/xiaolanbenlib/module/axios.js";
|
|
|
import type { TMessageHistories, TRequestBody, TAppendMessages } from "@/types/bot";
|
|
import type { TMessageHistories, TRequestBody, TAppendMessages } from "@/types/bot";
|
|
|
import { TextDecoder } from "text-encoding-shim";
|
|
import { TextDecoder } from "text-encoding-shim";
|
|
@@ -96,7 +96,7 @@ export const requestStream = <T>({
|
|
|
onStart();
|
|
onStart();
|
|
|
|
|
|
|
|
let reqTask: Taro.RequestTask<any>|undefined|null = undefined;
|
|
let reqTask: Taro.RequestTask<any>|undefined|null = undefined;
|
|
|
- const jsonParser = new JsonChunkParser();
|
|
|
|
|
|
|
+ const jsonParser = new ChunkParser();
|
|
|
jsonParser.onParseComplete((m) => {
|
|
jsonParser.onParseComplete((m) => {
|
|
|
onFinished(m);
|
|
onFinished(m);
|
|
|
});
|
|
});
|