Function createResponseStream

packages/ai/openai/src/OpenAiClient.ts:192–201

(
      options: Omit<typeof Generated.CreateResponse.Encoded, "stream">
    )

      )

    const createResponseStream = (
      options: Omit<typeof Generated.CreateResponse.Encoded, "stream">
    ): Stream.Stream<ResponseStreamEvent, AiError.AiError> => {
      const request = HttpClientRequest.post("/responses", {
        body: HttpBody.unsafeJson({ ...options, stream: true })
      })
      return streamRequest(request, ResponseStreamEvent).pipe(
        Stream.takeUntil((event) => event.type === "response.completed" || event.type === "response.incomplete")
      )
    }

    const createEmbedding = (
      options: typeof Generated.CreateEmbeddingRequest.Encoded