KotlinCoroutineApiApplication

Author: LOG-INFO

kotlin-coroutine-api/build.gradle.kts

@@ -0,0 +1,7 @@
+dependencies {
+    implementation(project(":domain"))
+    implementation(project(":core"))
+    implementation("org.springframework.boot:spring-boot-starter-webflux")
+    implementation("org.jetbrains.kotlinx:kotlinx-coroutines-reactor")
+    implementation(kotlin("stdlib-jdk8"))
+}

kotlin-coroutine-api/src/main/kotlin/info/log/kotlincoroutineapi/KotlinCoroutineApiApplication.kt

@@ -0,0 +1,13 @@
+package info.log.kotlincoroutineapi
+
+import org.springframework.boot.autoconfigure.SpringBootApplication
+import org.springframework.boot.runApplication
+
+
+@SpringBootApplication(scanBasePackages = ["info.log.kotlincoroutineapi", "info.log.core"])
+class KotlinCoroutineApiApplication {
+}
+
+fun main(args: Array<String>) {
+    runApplication<KotlinCoroutineApiApplication>(*args)
+}

kotlin-coroutine-api/src/main/kotlin/info/log/kotlincoroutineapi/web/HelloController.kt

@@ -0,0 +1,20 @@
+package info.log.kotlincoroutineapi.web
+
+import info.log.domain.Person
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.reactive.asFlow
+import org.slf4j.Logger
+import org.slf4j.LoggerFactory
+import org.springframework.web.bind.annotation.GetMapping
+import org.springframework.web.bind.annotation.RestController
+
+
+@RestController
+class HelloController {
+    val log: Logger = LoggerFactory.getLogger(this.javaClass)
+
+    @GetMapping("/hello")
+    suspend fun hello(): Flow<Person> {
+        return Person.createPeopleFluxRandomly().asFlow()
+    }
+}

kotlin-coroutine-api/src/main/resources/application.yml

@@ -0,0 +1,2 @@
+server:
+  port: 10000

settings.gradle.kts

@@ -3,5 +3,6 @@ rootProject.name = "java-concurrency-practice"
 include("platform-thread-api")
 include("virtual-thread-api")
 include("reactor-netty-api")
+include("kotlin-coroutine-api")
 include("domain")
 include("core")