@FunctionalInterfaceSE public interface ExchangeFunction
WebClient
の代替として使用できます。例:
ExchangeFunction exchangeFunction = ExchangeFunctions.create(new ReactorClientHttpConnector()); URI url = URI.create("https://example.com/resource"); ClientRequest request = ClientRequest.create(HttpMethod.GET, url).build(); Mono<String> bodyMono = exchangeFunction .exchange(request) .flatMap(response -> response.bodyToMono(String.class));
修飾子と型 | メソッドと説明 |
---|---|
reactor.core.publisher.Mono<ClientResponse> | exchange(ClientRequest request) 与えられたリクエストを ClientResponse プロミスと交換します。 |
default ExchangeFunction | filter(ExchangeFilterFunction filter) 指定された ExchangeFilterFunction で交換関数をフィルター処理すると、フィルター処理された ExchangeFunction が生成されます。 |
reactor.core.publisher.Mono<ClientResponse> exchange(ClientRequest request)
ClientResponse
プロミスと交換します。 注意 : なんらかの方法でレスポンスを処理する ExchangeFilterFunction
からこのメソッドを呼び出す場合、常にそのコンテンツを消費するか、WebClient
などによるさらなる処理のために下流に伝播するように特別な注意を払う必要があります。詳細については、リファレンスドキュメントを参照してください。
request
- 交換のリクエスト default ExchangeFunction filter(ExchangeFilterFunction filter)
ExchangeFilterFunction
で交換関数をフィルター処理すると、フィルター処理された ExchangeFunction
が生成されます。filter
- この交換に適用するフィルター ExchangeFilterFunction.apply(ExchangeFunction)