Function streamRequest

packages/ai/google/src/GoogleClient.ts:104–136

(
      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 decodeEvents = Schema.decode(Schema.ChunkFromSelf(Schema.parseJson(schema)))
      return httpClientOk.execute(request).pipe(
        Effect.map((r) => r.stream),
        Stream.unwrap,
        Stream.decodeText(),
        Stream.pipeThroughChannel(Sse.makeChannel()),
        Stream.mapChunksEffect((chunk) => decodeEvents(Chunk.map(chunk, (event) => event.data))),
        Stream.catchTags({
          RequestError: (error) =>
            AiError.HttpRequestError.fromRequestError({
              module: "GoogleClient",
              method: "streamRequest",
              error
            }),
          ResponseError: (error) =>
            AiError.HttpResponseError.fromResponseError({
              module: "GoogleClient",
              method: "streamRequest",
              error
            }),
          ParseError: (error) =>
            AiError.MalformedOutput.fromParseError({
              module: "GoogleClient",
              method: "streamRequest",
              error
            })
        })
      )
    }

    const generateContent: (
      request: typeof Generated.GenerateContentRequest.Encoded