>() {}) .toFuture()"> >() {}) .toFuture()"> >() {}) .toFuture()">
private fun getFutureResponse(ms: Long) = webClient.get()
.uri("<http://$domain:8888/delay/ms/$ms>")
.retrieve()
.bodyToMono(object : ParameterizedTypeReference<Map<*, *>>() {})
.toFuture()
WebClient 可以在這層就轉 Future
但是如果遇到多個非同步調用的時候,一者 Future 很難寫,二者 Future 會出現卡住逾時的議題
我上次的解法是還是先用 Mono 做
private fun getFutureResponse(ms: Long) = webClient.get()
.uri("<http://$domain:8888/delay/ms/$ms>")
.retrieve()
.bodyToMono(object : ParameterizedTypeReference<Map<*, *>>() {})
最後串完再一次轉 Future 就好