Function generateContentStream

packages/ai/google/src/GoogleClient.ts:167–178

(
      request: typeof Generated.GenerateContentRequest.Encoded
    )

    )

    const generateContentStream = (
      request: typeof Generated.GenerateContentRequest.Encoded
    ): Stream.Stream<Generated.GenerateContentResponse, AiError.AiError> => {
      const url = `/v1beta/models/${request.model}:streamGenerateContent`
      const httpRequest = HttpClientRequest.post(url, {
        urlParams: UrlParams.fromInput({ "alt": "sse" }),
        body: HttpBody.unsafeJson(request)
      })
      return streamRequest(httpRequest, Generated.GenerateContentResponse).pipe(
        Stream.takeUntil(hasFinishReason)
      )
    }

    return GoogleClient.of({
      client,