chore(internal): move StreamResponse method (#131)

Author: stainless-app[bot]

openai-java-core/src/main/kotlin/com/openai/core/handlers/SseHandler.kt

@@ -8,8 +8,8 @@ import com.openai.core.http.HttpResponse
 import com.openai.core.http.HttpResponse.Handler
 import com.openai.core.http.SseMessage
 import com.openai.core.http.StreamResponse
+import com.openai.core.http.map
 import com.openai.errors.OpenAIException
-import java.util.stream.Stream
 import kotlin.jvm.optionals.getOrNull
 
 @JvmSynthetic
@@ -129,11 +129,3 @@ internal inline fun <reified T> Handler<StreamResponse<SseMessage>>.mapJson():
                 }
             }
     }
-
-@JvmSynthetic
-internal fun <T, R> StreamResponse<T>.map(transform: (T) -> R): StreamResponse<R> =
-    object : StreamResponse<R> {
-        override fun stream(): Stream<R> = this@map.stream().map(transform)
-
-        override fun close() = this@map.close()
-    }

openai-java-core/src/main/kotlin/com/openai/core/http/StreamResponse.kt

@@ -6,3 +6,11 @@ interface StreamResponse<T> : AutoCloseable {
 
     fun stream(): Stream<T>
 }
+
+@JvmSynthetic
+internal fun <T, R> StreamResponse<T>.map(transform: (T) -> R): StreamResponse<R> =
+    object : StreamResponse<R> {
+        override fun stream(): Stream<R> = this@map.stream().map(transform)
+
+        override fun close() = this@map.close()
+    }

openai-java-core/src/main/kotlin/com/openai/services/async/CompletionServiceAsyncImpl.kt

@@ -9,7 +9,6 @@ import com.openai.core.JsonValue
 import com.openai.core.RequestOptions
 import com.openai.core.handlers.errorHandler
 import com.openai.core.handlers.jsonHandler
-import com.openai.core.handlers.map
 import com.openai.core.handlers.mapJson
 import com.openai.core.handlers.sseHandler
 import com.openai.core.handlers.withErrorHandler
@@ -18,6 +17,7 @@ import com.openai.core.http.HttpMethod
 import com.openai.core.http.HttpRequest
 import com.openai.core.http.HttpResponse.Handler
 import com.openai.core.http.StreamResponse
+import com.openai.core.http.map
 import com.openai.core.http.toAsync
 import com.openai.core.json
 import com.openai.errors.OpenAIError

openai-java-core/src/main/kotlin/com/openai/services/async/beta/ThreadServiceAsyncImpl.kt

@@ -7,7 +7,6 @@ import com.openai.core.JsonValue
 import com.openai.core.RequestOptions
 import com.openai.core.handlers.errorHandler
 import com.openai.core.handlers.jsonHandler
-import com.openai.core.handlers.map
 import com.openai.core.handlers.mapJson
 import com.openai.core.handlers.sseHandler
 import com.openai.core.handlers.withErrorHandler
@@ -16,6 +15,7 @@ import com.openai.core.http.HttpMethod
 import com.openai.core.http.HttpRequest
 import com.openai.core.http.HttpResponse.Handler
 import com.openai.core.http.StreamResponse
+import com.openai.core.http.map
 import com.openai.core.http.toAsync
 import com.openai.core.json
 import com.openai.errors.OpenAIError

openai-java-core/src/main/kotlin/com/openai/services/async/beta/threads/RunServiceAsyncImpl.kt

@@ -7,7 +7,6 @@ import com.openai.core.JsonValue
 import com.openai.core.RequestOptions
 import com.openai.core.handlers.errorHandler
 import com.openai.core.handlers.jsonHandler
-import com.openai.core.handlers.map
 import com.openai.core.handlers.mapJson
 import com.openai.core.handlers.sseHandler
 import com.openai.core.handlers.withErrorHandler
@@ -16,6 +15,7 @@ import com.openai.core.http.HttpMethod
 import com.openai.core.http.HttpRequest
 import com.openai.core.http.HttpResponse.Handler
 import com.openai.core.http.StreamResponse
+import com.openai.core.http.map
 import com.openai.core.http.toAsync
 import com.openai.core.json
 import com.openai.errors.OpenAIError

openai-java-core/src/main/kotlin/com/openai/services/async/chat/CompletionServiceAsyncImpl.kt

@@ -9,7 +9,6 @@ import com.openai.core.JsonValue
 import com.openai.core.RequestOptions
 import com.openai.core.handlers.errorHandler
 import com.openai.core.handlers.jsonHandler
-import com.openai.core.handlers.map
 import com.openai.core.handlers.mapJson
 import com.openai.core.handlers.sseHandler
 import com.openai.core.handlers.withErrorHandler
@@ -18,6 +17,7 @@ import com.openai.core.http.HttpMethod
 import com.openai.core.http.HttpRequest
 import com.openai.core.http.HttpResponse.Handler
 import com.openai.core.http.StreamResponse
+import com.openai.core.http.map
 import com.openai.core.http.toAsync
 import com.openai.core.json
 import com.openai.errors.OpenAIError

openai-java-core/src/main/kotlin/com/openai/services/blocking/CompletionServiceImpl.kt

@@ -9,14 +9,14 @@ import com.openai.core.JsonValue
 import com.openai.core.RequestOptions
 import com.openai.core.handlers.errorHandler
 import com.openai.core.handlers.jsonHandler
-import com.openai.core.handlers.map
 import com.openai.core.handlers.mapJson
 import com.openai.core.handlers.sseHandler
 import com.openai.core.handlers.withErrorHandler
 import com.openai.core.http.HttpMethod
 import com.openai.core.http.HttpRequest
 import com.openai.core.http.HttpResponse.Handler
 import com.openai.core.http.StreamResponse
+import com.openai.core.http.map
 import com.openai.core.json
 import com.openai.errors.OpenAIError
 import com.openai.models.Completion

openai-java-core/src/main/kotlin/com/openai/services/blocking/beta/ThreadServiceImpl.kt

@@ -7,14 +7,14 @@ import com.openai.core.JsonValue
 import com.openai.core.RequestOptions
 import com.openai.core.handlers.errorHandler
 import com.openai.core.handlers.jsonHandler
-import com.openai.core.handlers.map
 import com.openai.core.handlers.mapJson
 import com.openai.core.handlers.sseHandler
 import com.openai.core.handlers.withErrorHandler
 import com.openai.core.http.HttpMethod
 import com.openai.core.http.HttpRequest
 import com.openai.core.http.HttpResponse.Handler
 import com.openai.core.http.StreamResponse
+import com.openai.core.http.map
 import com.openai.core.json
 import com.openai.errors.OpenAIError
 import com.openai.models.AssistantStreamEvent

openai-java-core/src/main/kotlin/com/openai/services/blocking/beta/threads/RunServiceImpl.kt

@@ -7,14 +7,14 @@ import com.openai.core.JsonValue
 import com.openai.core.RequestOptions
 import com.openai.core.handlers.errorHandler
 import com.openai.core.handlers.jsonHandler
-import com.openai.core.handlers.map
 import com.openai.core.handlers.mapJson
 import com.openai.core.handlers.sseHandler
 import com.openai.core.handlers.withErrorHandler
 import com.openai.core.http.HttpMethod
 import com.openai.core.http.HttpRequest
 import com.openai.core.http.HttpResponse.Handler
 import com.openai.core.http.StreamResponse
+import com.openai.core.http.map
 import com.openai.core.json
 import com.openai.errors.OpenAIError
 import com.openai.models.AssistantStreamEvent

openai-java-core/src/main/kotlin/com/openai/services/blocking/chat/CompletionServiceImpl.kt

@@ -9,14 +9,14 @@ import com.openai.core.JsonValue
 import com.openai.core.RequestOptions
 import com.openai.core.handlers.errorHandler
 import com.openai.core.handlers.jsonHandler
-import com.openai.core.handlers.map
 import com.openai.core.handlers.mapJson
 import com.openai.core.handlers.sseHandler
 import com.openai.core.handlers.withErrorHandler
 import com.openai.core.http.HttpMethod
 import com.openai.core.http.HttpRequest
 import com.openai.core.http.HttpResponse.Handler
 import com.openai.core.http.StreamResponse
+import com.openai.core.http.map
 import com.openai.core.json
 import com.openai.errors.OpenAIError
 import com.openai.models.ChatCompletion