インターフェース ReactorHttpExchangeAdapter
- すべてのスーパーインターフェース:
HttpExchangeAdapter
- すべての既知の実装クラス:
AbstractReactorHttpExchangeAdapter
,WebClientAdapter
リアクティブな HTTP クライアントを HttpServiceProxyFactory から抽象化し、プラグイン可能にするための契約。
- 導入:
- 6.1
- 作成者:
- Rossen Stoyanchev
メソッドのサマリー
修飾子と型メソッド説明reactor.core.publisher.Mono<ResponseEntity<VoidSE>>
exchangeForBodilessEntityMono
(HttpRequestValues requestValues) レスポンスステータスとヘッダーへの追加アクセスを備えたexchangeForMono(HttpRequestValues)
のバリアント。<T> reactor.core.publisher.Flux<T>
exchangeForBodyFlux
(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType) 指定されたリクエストを実行し、レスポンスの内容を指定された型の要素を持つストリームにデコードします。<T> reactor.core.publisher.Mono<T>
exchangeForBodyMono
(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType) 指定されたリクエストを実行し、レスポンスのコンテンツを指定された型にデコードします。<T> reactor.core.publisher.Mono<ResponseEntity<reactor.core.publisher.Flux<T>>>
exchangeForEntityFlux
(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType) レスポンスステータスとヘッダーへの追加アクセスを備えたexchangeForBodyFlux(HttpRequestValues, ParameterizedTypeReference)
のバリアント。<T> reactor.core.publisher.Mono<ResponseEntity<T>>
exchangeForEntityMono
(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType) レスポンスステータスとヘッダーへの追加アクセスを備えたexchangeForBodyMono(HttpRequestValues, ParameterizedTypeReference)
のバリアント。reactor.core.publisher.Mono<HttpHeaders>
exchangeForHeadersMono
(HttpRequestValues requestValues) 指定されたリクエストを実行し、レスポンスコンテンツを解放し、レスポンスヘッダーを返します。reactor.core.publisher.Mono<VoidSE>
exchangeForMono
(HttpRequestValues requestValues) 指定されたリクエストを実行し、レスポンスコンテンツがある場合はそれを解放します。同期 (ブロッキング) メソッド署名を使用して、HTTP サービスメソッドからのレスポンスをブロックする設定された時間を返します。設定されたReactiveAdapterRegistry
を返します。インターフェース org.springframework.web.service.invoker.HttpExchangeAdapter から継承されたメソッド
exchange, exchangeForBodilessEntity, exchangeForBody, exchangeForEntity, exchangeForHeaders, supportsRequestAttributes
メソッドの詳細
getReactiveAdapterRegistry
ReactiveAdapterRegistry getReactiveAdapterRegistry()設定されたReactiveAdapterRegistry
を返します。getBlockTimeout
同期 (ブロッキング) メソッド署名を使用して、HTTP サービスメソッドからのレスポンスをブロックする設定された時間を返します。デフォルトでは設定されていません。この場合の動作は、基礎となる HTTP クライアントの接続およびリクエストのタイムアウト設定に依存します。基礎となる HTTP クライアントでタイムアウト値を直接構成することをお勧めします。これにより、そのような設定をより詳細に制御できるようになります。
exchangeForMono
指定されたリクエストを実行し、レスポンスコンテンツがある場合はそれを解放します。- パラメーター:
requestValues
- 実行するリクエスト- 戻り値:
- リクエストが完全に実行され、レスポンスの内容が解放されると完了する
Mono
。
exchangeForHeadersMono
指定されたリクエストを実行し、レスポンスコンテンツを解放し、レスポンスヘッダーを返します。- パラメーター:
requestValues
- 実行するリクエスト- 戻り値:
- レスポンスヘッダーを返す
Mono
は、リクエストが完全に実行され、レスポンスコンテンツが解放されます。
exchangeForBodyMono
<T> reactor.core.publisher.Mono<T> exchangeForBodyMono(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType) 指定されたリクエストを実行し、レスポンスのコンテンツを指定された型にデコードします。- 型パラメーター:
T
- レスポンスがデコードされる型- パラメーター:
requestValues
- 実行するリクエストbodyType
- デコードする対象の型- 戻り値:
- デコードされたレスポンスを返す
Mono
。
exchangeForBodyFlux
<T> reactor.core.publisher.Flux<T> exchangeForBodyFlux(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType) 指定されたリクエストを実行し、レスポンスの内容を指定された型の要素を持つストリームにデコードします。- 型パラメーター:
T
- レスポンスがデコードされる型- パラメーター:
requestValues
- 実行するリクエストbodyType
- デコード先のターゲットストリーム要素の型- 戻り値:
- デコードされたストリーム要素を持つ
Flux
。
exchangeForBodilessEntityMono
reactor.core.publisher.Mono<ResponseEntity<VoidSE>> exchangeForBodilessEntityMono(HttpRequestValues requestValues) レスポンスステータスとヘッダーへの追加アクセスを備えたexchangeForMono(HttpRequestValues)
のバリアント。exchangeForEntityMono
<T> reactor.core.publisher.Mono<ResponseEntity<T>> exchangeForEntityMono(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType) レスポンスステータスとヘッダーへの追加アクセスを備えたexchangeForBodyMono(HttpRequestValues, ParameterizedTypeReference)
のバリアント。exchangeForEntityFlux
<T> reactor.core.publisher.Mono<ResponseEntity<reactor.core.publisher.Flux<T>>> exchangeForEntityFlux(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType) レスポンスステータスとヘッダーへの追加アクセスを備えたexchangeForBodyFlux(HttpRequestValues, ParameterizedTypeReference)
のバリアント。