Function demoTextStreamParser

web/src/lib/sse-parser.ts:1011–1054

* 演示如何使用纯文本流解析器

()

 * 演示如何使用纯文本流解析器
 */
function demoTextStreamParser(): void {
  const textParser = new SseTextStreamParser();
  
  // 方式1：使用配置对象
  textParser.connect({
    method: 'POST',
    url: '/api/stream/text',
    param: { prompt: 'Hello, world!' },
    onText: (newText, fullText) => {
      console.log('新文本片段:', newText);
      console.log('完整文本:', fullText);
    },
    onComplete: (fullText) => {
      console.log('文本接收完成:', fullText);
    },
    close: () => {
      console.log('连接已关闭');
    },
    error: (err) => {
      console.error('连接错误:', err);
    }
  });
  
  // 方式2：使用参数形式
  // textParser.connect(
  //   'POST',
  //   '/api/stream/text',
  //   { prompt: 'Hello, world!' },
  //   (newText, fullText) => console.log('新文本:', newText),
  //   (fullText) => console.log('完成:', fullText),
  //   () => console.log('关闭'),
  //   (err) => console.error('错误:', err)
  // );
  
  // 获取当前累积的文本
  setTimeout(() => {
    console.log('当前文本:', textParser.getFullText());
  }, 5000);
  
  // 10秒后断开连接
  setTimeout(() => {
    textParser.disconnect();
  }, 10000);
}

function demoWithSSE(): void {
  const jsonStream = new SseJsonStreamParser(true);