Closed DybekK closed 11 months ago
This PR adds streaming support for Create chat completion endpoint using ZIO as a streams implementation.
Here are the main changes made in this PR:
package sttp.openai.streaming
package object zio { implicit class extension(val client: OpenAI) { def createStreamedChatCompletion(chatBody: ChatBody): StreamRequest[Either[OpenAIException, Stream[Throwable, ChatChunkResponse]], ZioStreams] } }
- integration tests have been added using HttpClientZioBackend.stub
This PR adds streaming support for Create chat completion endpoint using ZIO as a streams implementation.
Here are the main changes made in this PR:
package object zio { implicit class extension(val client: OpenAI) { def createStreamedChatCompletion(chatBody: ChatBody): StreamRequest[Either[OpenAIException, Stream[Throwable, ChatChunkResponse]], ZioStreams] } }