File tree Expand file tree Collapse file tree 1 file changed +6
-2
lines changed
openai-java-core/src/main/kotlin/com/openai/core/handlers Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -18,8 +18,9 @@ internal fun sseHandler(jsonMapper: JsonMapper): Handler<StreamResponse<SseMessa
18
18
object : Handler <StreamResponse <SseMessage >> {
19
19
20
20
override fun handle (response : HttpResponse ): StreamResponse <SseMessage > {
21
+ val reader = response.body().bufferedReader()
21
22
val sequence = sequence {
22
- response.body().bufferedReader() .useLines { lines ->
23
+ reader .useLines { lines ->
23
24
val state = SseState (jsonMapper)
24
25
var done = false
25
26
for (line in lines) {
@@ -60,7 +61,10 @@ internal fun sseHandler(jsonMapper: JsonMapper): Handler<StreamResponse<SseMessa
60
61
return object : StreamResponse <SseMessage > {
61
62
override fun stream (): Stream <SseMessage > = sequence.asStream()
62
63
63
- override fun close () = response.close()
64
+ override fun close () {
65
+ reader.close()
66
+ response.close()
67
+ }
64
68
}
65
69
}
66
70
}
You can’t perform that action at this time.
0 commit comments