Method processStreamResponse

src/main/aiHandler.ts:246–277

* 处理流式响应

(
    reader: ReadableStreamDefaultReader<Uint8Array>,
    parser: ReturnType<typeof createParser>,
    event: Electron.IpcMainInvokeEvent,
    eventChannel: string,
    fullResponse: { value: string },
    fullReasoning: { value: string }
  )

   * 处理流式响应
   */
  private async processStreamResponse(
    reader: ReadableStreamDefaultReader<Uint8Array>,
    parser: ReturnType<typeof createParser>,
    event: Electron.IpcMainInvokeEvent,
    eventChannel: string,
    fullResponse: { value: string },
    fullReasoning: { value: string }
  ): Promise<void> {
    const decoder = new TextDecoder()

    try {
      while (true) {
        const { done, value } = await reader.read()
        if (done) break

        const chunk = decoder.decode(value, { stream: true })
        parser.feed(chunk)
      }

      this.sendComplete(event, eventChannel, fullResponse.value, fullReasoning.value)
    } catch (error) {
      if (error instanceof Error && error.name === 'AbortError') {
        this.sendComplete(event, eventChannel, fullResponse.value, fullReasoning.value)
      } else {
        this.sendError(
          event,
          eventChannel,
          error instanceof Error ? error.message : 'Unknown error'
        )
      }
    }
  }

  public async sendMessageStreaming(
    event: Electron.IpcMainInvokeEvent,