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

Using Retrieve instead of AwaitExchange

This commit is contained in:
Ali Dehghani 2020-05-30 21:58:48 +04:30
parent 6076d4da3b
commit 6b3b45923b
2 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -2,12 +2,11 @@ package com.baeldung.nonblockingcoroutines.controller
import com.baeldung.nonblockingcoroutines.model.Product import com.baeldung.nonblockingcoroutines.model.Product
import com.baeldung.nonblockingcoroutines.repository.ProductRepositoryCoroutines import com.baeldung.nonblockingcoroutines.repository.ProductRepositoryCoroutines
import kotlinx.coroutines.CoroutineStart
import kotlinx.coroutines.Deferred import kotlinx.coroutines.Deferred
import kotlinx.coroutines.FlowPreview import kotlinx.coroutines.FlowPreview
import kotlinx.coroutines.GlobalScope
import kotlinx.coroutines.CoroutineStart
import kotlinx.coroutines.coroutineScope
import kotlinx.coroutines.async import kotlinx.coroutines.async
import kotlinx.coroutines.coroutineScope
import kotlinx.coroutines.flow.Flow import kotlinx.coroutines.flow.Flow
import org.springframework.beans.factory.annotation.Autowired import org.springframework.beans.factory.annotation.Autowired
import org.springframework.http.MediaType.APPLICATION_JSON import org.springframework.http.MediaType.APPLICATION_JSON
@ -15,7 +14,6 @@ import org.springframework.web.bind.annotation.GetMapping
import org.springframework.web.bind.annotation.PathVariable import org.springframework.web.bind.annotation.PathVariable
import org.springframework.web.reactive.function.client.WebClient import org.springframework.web.reactive.function.client.WebClient
import org.springframework.web.reactive.function.client.awaitBody import org.springframework.web.reactive.function.client.awaitBody
import org.springframework.web.reactive.function.client.awaitExchange
class ProductControllerCoroutines { class ProductControllerCoroutines {
@Autowired @Autowired
@ -38,7 +36,7 @@ class ProductControllerCoroutines {
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>() .retrieve().awaitBody<Int>()
} }
ProductStockView(product.await()!!, quantity.await()) ProductStockView(product.await()!!, quantity.await())
} }

3
spring-boot-modules/spring-boot-kotlin/src/main/kotlin/com/baeldung/nonblockingcoroutines/handlers/ProductsHandler.kt
View File

@ -12,7 +12,6 @@ import org.springframework.http.MediaType
import org.springframework.stereotype.Component import org.springframework.stereotype.Component
import org.springframework.web.reactive.function.client.WebClient import org.springframework.web.reactive.function.client.WebClient
import org.springframework.web.reactive.function.client.awaitBody import org.springframework.web.reactive.function.client.awaitBody
import org.springframework.web.reactive.function.client.awaitExchange
import org.springframework.web.reactive.function.server.ServerRequest import org.springframework.web.reactive.function.server.ServerRequest
import org.springframework.web.reactive.function.server.ServerResponse import org.springframework.web.reactive.function.server.ServerResponse
import org.springframework.web.reactive.function.server.bodyAndAwait import org.springframework.web.reactive.function.server.bodyAndAwait
@ -37,7 +36,7 @@ class ProductsHandler(
webClient.get() webClient.get()
.uri("/stock-service/product/$id/quantity") .uri("/stock-service/product/$id/quantity")
.accept(MediaType.APPLICATION_JSON) .accept(MediaType.APPLICATION_JSON)
.awaitExchange().awaitBody<Int>() .retrieve().awaitBody<Int>()
} }
return ServerResponse.ok().json().bodyAndAwait(ProductStockView(product.await()!!, quantity.await())) return ServerResponse.ok().json().bodyAndAwait(ProductStockView(product.await()!!, quantity.await()))
} }