Exchange

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 完成後，會檢查回應本文，如果未消耗，則會釋放以防止記憶體和連線洩漏。因此，無法在下游進一步解碼回應。是否需要解碼回應取決於提供的函數如何宣告。