bump ktor

Trendyol · Feb 17, 2025 · 9744741 · 9744741
1 parent 8ec7228
commit 9744741
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 8 deletions.
diff --git a/examples/ktor-example/build.gradle.kts b/examples/ktor-example/build.gradle.kts
@@ -33,7 +33,6 @@ dependencies {
 }
 
 dependencies {
-  testImplementation(libs.ktor.server.tests.jvm)
   testImplementation(libs.kotest.property)
   testImplementation(libs.kotest.runner.junit5)
   testImplementation(libs.logback.classic)

diff --git a/examples/ktor-example/src/main/kotlin/stove/ktor/example/Application.kt b/examples/ktor-example/src/main/kotlin/stove/ktor/example/Application.kt
@@ -32,11 +32,11 @@ fun run(
     mainModule(config, applicationOverrides)
   }
 
-  applicationEngine.environment.monitor.subscribe(ApplicationStarted) {
+  applicationEngine.monitor.subscribe(ApplicationStarted) {
     it.get<ExampleAppConsumer<String, Any>>().start()
   }
 
-  applicationEngine.environment.monitor.subscribe(ApplicationStopping) {
+  applicationEngine.monitor.subscribe(ApplicationStopping) {
     it.get<ExampleAppConsumer<String, Any>>().stop()
   }
 

diff --git a/gradle/libs.versions.toml b/gradle/libs.versions.toml
@@ -24,7 +24,7 @@ kafka-streams-registry = "7.8.1"
 dokka = "2.0.0"
 knit = "0.5.0"
 kover = "0.9.1"
-ktor = "2.3.13"
+ktor = "3.1.0"
 koin = "4.0.2"
 r2dbc-spi = "1.0.0.RELEASE"
 r2dbc-postgresql = "0.8.13.RELEASE"

diff --git a/lib/stove-testing-e2e-http/src/main/kotlin/com/trendyol/stove/testing/e2e/http/streaming.kt b/lib/stove-testing-e2e-http/src/main/kotlin/com/trendyol/stove/testing/e2e/http/streaming.kt
@@ -13,8 +13,8 @@ import kotlinx.coroutines.flow.*
 fun <T> HttpStatement.readJsonTextStream(transform: suspend (line: String) -> T): Flow<T> = flow {
   execute {
     check(it.status.isSuccess()) { "Request failed with status: ${it.status}" }
-    while (!it.content.isClosedForRead) {
-      it.content.readUTF8LineNonEmpty { line -> emit(transform(line)) }
+    while (!it.rawContent.isClosedForRead) {
+      it.rawContent.readUTF8LineNonEmpty { line -> emit(transform(line)) }
     }
   }
 }
@@ -24,8 +24,8 @@ fun <T> HttpStatement.readJsonTextStream(transform: suspend (line: String) -> T)
 fun <T> HttpStatement.readJsonContentStream(transform: suspend (line: ByteReadChannel) -> T): Flow<T> = flow {
   execute {
     check(it.status.isSuccess()) { "Request failed with status: ${it.status}" }
-    while (!it.content.isClosedForRead) {
-      it.content.readUTF8LineNonEmpty { line -> emit(transform(ByteReadChannel(line.toByteArray()))) }
+    while (!it.rawContent.isClosedForRead) {
+      it.rawContent.readUTF8LineNonEmpty { line -> emit(transform(ByteReadChannel(line.toByteArray()))) }
     }
   }
 }