Add CoroutineHttpService for handle request within Coroutine suspend

kotlin/src/main/kotlin/com/linecorp/armeria/server/kotlin/CoroutineHttpService.kt

@@ -0,0 +1,42 @@
+/*
+ * Copyright 2024 LINE Corporation
+ *
+ * LINE Corporation licenses this file to you under the Apache License,
+ * version 2.0 (the "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at:
+ *
+ *   https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations
+ * under the License.
+ */
+
+package com.linecorp.armeria.server.kotlin
+
+import com.linecorp.armeria.common.HttpRequest
+import com.linecorp.armeria.common.HttpResponse
+import com.linecorp.armeria.common.kotlin.asCoroutineContext
+import com.linecorp.armeria.server.HttpService
+import com.linecorp.armeria.server.ServiceRequestContext
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.future.future
+
+/**
+ * An Coroutine-based [HttpService]
+ */
+fun interface CoroutineHttpService : HttpService {
+
+    /**
+     * invoke the suspendedServe method within the CoroutineScope
+     */
+    override fun serve(ctx: ServiceRequestContext, req: HttpRequest): HttpResponse {
+        return HttpResponse.of(CoroutineScope(ctx.asCoroutineContext()).future { // Do we also need to add user context?
+            suspendedServe(ctx, req)
+        })
+    }
+
+    suspend fun suspendedServe(ctx: ServiceRequestContext, req: HttpRequest): HttpResponse
+}

kotlin/src/test/kotlin/com/linecorp/armeria/server/kotlin/CoroutineHttpServiceTest.kt

@@ -0,0 +1,57 @@
+/*
+ * Copyright 2024 LINE Corporation
+ *
+ * LINE Corporation licenses this file to you under the Apache License,
+ * version 2.0 (the "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at:
+ *
+ *   https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations
+ * under the License.
+ */
+
+package com.linecorp.armeria.server.kotlin
+
+import com.linecorp.armeria.common.HttpRequest
+import com.linecorp.armeria.common.HttpResponse
+import com.linecorp.armeria.common.HttpStatus
+import com.linecorp.armeria.server.ServerBuilder
+import com.linecorp.armeria.server.ServiceRequestContext
+import com.linecorp.armeria.testing.junit5.server.ServerExtension
+import kotlinx.coroutines.test.runTest
+import org.assertj.core.api.Assertions
+import org.junit.jupiter.api.Test
+import org.junit.jupiter.api.extension.RegisterExtension
+
+class CoroutineHttpServiceTest {
+
+    companion object {
+        @JvmField
+        @RegisterExtension
+        val server =
+                object : ServerExtension() {
+                    override fun configure(sb: ServerBuilder) {
+                        sb.service(
+                                "/hello",
+                                object : CoroutineHttpService {
+                                    override suspend fun suspendedServe(ctx: ServiceRequestContext, req: HttpRequest): HttpResponse {
+                                        return HttpResponse.of("hello world")
+                                    }
+                                }
+                        )
+                    }
+                }
+    }
+
+    @Test
+    fun `Should return hello world when call hello coroutine service`() = runTest {
+        val response = server.blockingWebClient().get("/hello")
+
+        Assertions.assertThat(response.status()).isEqualTo(HttpStatus.OK)
+        Assertions.assertThat(response.contentUtf8()).isEqualTo("hello world")
+    }
+}