delete domain module, and simplify APIs

Author: LOG-INFO

core/build.gradle.kts

@@ -1,7 +1,6 @@
 import org.springframework.boot.gradle.tasks.bundling.BootJar
 
 dependencies {
-    implementation(project(":domain"))
     implementation("io.projectreactor:reactor-core")
     implementation("io.micrometer:micrometer-core")
     implementation("org.springframework.boot:spring-boot")

core/src/main/kotlin/info/log/core/client/HelloClient.kt

@@ -1,9 +1,8 @@
 package info.log.core.client
 
-import info.log.domain.Person
 import org.springframework.web.service.annotation.GetExchange
 
 interface HelloClient {
     @GetExchange("/hello")
-    fun hello(): List<Person>
+    fun hello()
 }

domain/build.gradle.kts

@@ -1,5 +1,4 @@
 dependencies {
-    implementation(project(":domain"))
     implementation(project(":core"))
     implementation("org.springframework.boot:spring-boot-starter-webflux")
     implementation("org.jetbrains.kotlinx:kotlinx-coroutines-reactor")

domain/src/main/kotlin/info/log/domain/Person.kt

@@ -1,20 +1,17 @@
 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 kotlinx.coroutines.reactive.awaitSingle
 import org.springframework.web.bind.annotation.GetMapping
 import org.springframework.web.bind.annotation.RestController
+import reactor.core.publisher.Mono
+import java.time.Duration.ofMillis
 
 
 @RestController
 class HelloController {
-    val log: Logger = LoggerFactory.getLogger(this.javaClass)
-
     @GetMapping("/hello")
-    suspend fun hello(): Flow<Person> {
-        return Person.createPeopleFluxRandomly().asFlow()
+    suspend fun hello(): Long {
+        return Mono.delay(ofMillis(100))
+            .awaitSingle()
     }
 }

domain/src/main/resources/application.yml

@@ -1,5 +1,4 @@
 dependencies {
-    implementation(project(":domain"))
     implementation(project(":core"))
     implementation("org.springframework.boot:spring-boot-starter-web")
     implementation(kotlin("stdlib-jdk8"))

kotlin-coroutine-api/build.gradle.kts

@@ -1,18 +1,13 @@
 package info.log.platformthreadapi.web
 
-import info.log.domain.Person
-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")
-    fun hello(): List<Person> {
-        return Person.createPeopleListRandomly()
+    fun hello() {
+        Thread.sleep(100)
     }
 }

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

@@ -2,7 +2,7 @@ server:
   port: 10000
   tomcat:
     threads:
-      max: 500
+      max: 2000
       min-spare: 10
     max-connections: 8192
     accept-count: 100