Function streamRequest

packages/ai/openrouter/src/OpenRouterClient.ts:122–155

(
    request: HttpClientRequest.HttpClientRequest,
    schema: Schema.Schema<A, I, R>
  )

  })

  const streamRequest = <A, I, R>(
    request: HttpClientRequest.HttpClientRequest,
    schema: Schema.Schema<A, I, R>
  ): Stream.Stream<A, AiError.AiError, R> => {
    const decodeEvent = Schema.decode(Schema.parseJson(schema))
    return httpClientOk.execute(request).pipe(
      Effect.map((r) => r.stream),
      Stream.unwrapScoped,
      Stream.decodeText(),
      Stream.pipeThroughChannel(Sse.makeChannel()),
      Stream.takeWhile((event) => event.data !== "[DONE]"),
      Stream.mapEffect((event) => decodeEvent(event.data)),
      Stream.catchTags({
        RequestError: (error) =>
          AiError.HttpRequestError.fromRequestError({
            module: "OpenRouterClient",
            method: "streamRequest",
            error
          }),
        ResponseError: (error) =>
          AiError.HttpResponseError.fromResponseError({
            module: "OpenRouterClient",
            method: "streamRequest",
            error
          }),
        ParseError: (error) =>
          AiError.MalformedOutput.fromParseError({
            module: "OpenRouterClient",
            method: "streamRequest",
            error
          })
      })
    )
  }

  const createChatCompletion: (
    options: typeof Generated.ChatGenerationParams.Encoded