交易所

Hunyuan 7b 中英对照 Exchange

exchangeToMono() 和 exchangeToFlux() 方法（在 Kotlin 中对应为 awaitExchange { } 和 exchangeToFlow { }）对于需要更多控制的高级场景非常有用，例如根据响应状态以不同的方式解码响应：

Java

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();
			}
		});

Kotlin

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 完成执行后，会检查响应体；如果响应体没有被消费掉，就会将其释放出来，以防止内存和连接泄漏。因此，后续就无法再对响应体进行解码了。如果有必要解码响应体，那就需要由提供的函数来决定如何进行解码。