Function pull

src/services/api/openAICompatWsV2Native.ts:222–268

(controller)

        signal?.addEventListener('abort', abortHandler, { once: true })
      },
      async pull(controller) {
        if (streamClosed) return
        try {
          await ensureStarted()
          while (!signal?.aborted) {
            const raw = await binding.wsV2Next?.(sessionId)
            if (!raw) {
              throw new Error('WS v2 stream closed before completion')
            }
            const message = JSON.parse(raw) as Record<string, unknown>
            if (message.id === requestId) {
              if ('error' in message) {
                throw new Error(`WS v2 request rejected: ${JSON.stringify(message.error)}`)
              }
              continue
            }
            if (!isRequestNotification(message, requestId)) {
              continue
            }
            const method = message.method
            const params = (message.params ?? {}) as { data?: unknown; error?: unknown }
            if (method === 'chat.completions.delta') {
              if (typeof params.data === 'string') {
                controller.enqueue(encodeSseFrame(params.data))
                return
              }
              continue
            }
            if (method === 'chat.completions.completed') {
              controller.enqueue(encodeSseFrame('[DONE]'))
              safeCloseController(controller)
              await closeAfterTerminalFrame()
              return
            }
            if (method === 'chat.completions.error') {
              throw new Error(`WS v2 stream error: ${JSON.stringify(params.error)}`)
            }
          }
          safeCloseController(controller)
          await closeAfterTerminalFrame()
        } catch (error) {
          streamClosed = true
          removeAbortHandler()
          await close()
          controller.error(error)
        }
      },
      async cancel() {
        streamClosed = true
        removeAbortHandler()