iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

BAEL-2378 Fix Non-blocking Spring Boot with Kotlin Coroutines

Browse Source
This commit is contained in:
Alexander Molochko 2019-09-15 17:13:30 +03:00
parent 9154f5e062
commit 0a4f2a1148
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
spring-boot-kotlin/src/main/kotlin/com/baeldung/nonblockingcoroutines/controller/ProductControllerCoroutines.kt
View File

@ -5,6 +5,8 @@ import com.baeldung.nonblockingcoroutines.repository.ProductRepositoryCoroutines
import kotlinx.coroutines.Deferred import kotlinx.coroutines.Deferred
import kotlinx.coroutines.FlowPreview import kotlinx.coroutines.FlowPreview
import kotlinx.coroutines.GlobalScope import kotlinx.coroutines.GlobalScope
import kotlinx.coroutines.CoroutineStart
import kotlinx.coroutines.coroutineScope
import kotlinx.coroutines.async import kotlinx.coroutines.async
import kotlinx.coroutines.flow.Flow import kotlinx.coroutines.flow.Flow
import org.springframework.beans.factory.annotation.Autowired import org.springframework.beans.factory.annotation.Autowired
@ -28,17 +30,17 @@ class ProductControllerCoroutines {
} }
@GetMapping("/{id}/stock") @GetMapping("/{id}/stock")
suspend fun findOneInStock(@PathVariable id: Int): ProductStockView { suspend fun findOneInStock(@PathVariable id: Int): ProductStockView = coroutineScope {
val product: Deferred<Product?> = GlobalScope.async { val product: Deferred<Product?> = async(start = CoroutineStart.LAZY) {
productRepository.getProductById(id) productRepository.getProductById(id)
} }
val quantity: Deferred<Int> = GlobalScope.async { val quantity: Deferred<Int> = async(start = CoroutineStart.LAZY) {
webClient.get() webClient.get()
.uri("/stock-service/product/$id/quantity") .uri("/stock-service/product/$id/quantity")
.accept(APPLICATION_JSON) .accept(APPLICATION_JSON)
.awaitExchange().awaitBody<Int>() .awaitExchange().awaitBody<Int>()
} }
return ProductStockView(product.await()!!, quantity.await()) ProductStockView(product.await()!!, quantity.await())
} }
@FlowPreview @FlowPreview