Method processStreamResponse

src/main/aiHandler.ts:247–276

(
    requestId: string,
    reader: ReadableStreamDefaultReader<Uint8Array>,
    parser: EventSourceParser
  )

  }

  private async processStreamResponse(
    requestId: string,
    reader: ReadableStreamDefaultReader<Uint8Array>,
    parser: EventSourceParser
  ): Promise<void> {
    const decoder = new TextDecoder()

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

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

      this.finalizeComplete(requestId)
    } catch (error) {
      if (error instanceof Error && error.name === 'AbortError') {
        this.finalizeComplete(requestId)
        return
      }

      this.finalizeTerminalError(
        requestId,
        error instanceof Error ? error.message : 'Unknown error'
      )
    }
  }

  public async sendMessageStreaming(
    event: Electron.IpcMainInvokeEvent,