交換
`exchangeToMono()` 和 `exchangeToFlux()` 方法(或者在 Kotlin 中是 `awaitExchange { }` 和 `exchangeToFlow { }`)對於需要更多控制的更高階情況很有用,例如根據響應狀態以不同方式解碼響應。
-
Java
-
Kotlin
Mono<Person> entityMono = client.get()
.uri("/persons/1")
.accept(MediaType.APPLICATION_JSON)
.exchangeToMono(response -> {
if (response.statusCode().equals(HttpStatus.OK)) {
return response.bodyToMono(Person.class);
}
else {
// Turn to error
return response.createError();
}
});
val entity = client.get()
.uri("/persons/1")
.accept(MediaType.APPLICATION_JSON)
.awaitExchange {
if (response.statusCode() == HttpStatus.OK) {
return response.awaitBody<Person>()
}
else {
throw response.createExceptionAndAwait()
}
}
使用上述方法時,返回的 `Mono` 或 `Flux` 完成後,會檢查響應體,如果未被消費,則會釋放以防止記憶體和連線洩漏。因此,響應無法在下游進一步解碼。需要由提供的函式宣告如何解碼響應。