インターフェース ReactorHttpExchangeAdapter

すべてのスーパーインターフェース:
HttpExchangeAdapter
すべての既知の実装クラス:
AbstractReactorHttpExchangeAdapterWebClientAdapter

public interface ReactorHttpExchangeAdapter extends HttpExchangeAdapter
リアクティブな HTTP クライアントを HttpServiceProxyFactory から抽象化し、プラグイン可能にするための契約。
導入:
6.1
作成者:
Rossen Stoyanchev
  • メソッドの詳細

    • getReactiveAdapterRegistry

      ReactiveAdapterRegistry getReactiveAdapterRegistry()
      設定された ReactiveAdapterRegistry を返します。
    • getBlockTimeout

      @Nullable DurationSE getBlockTimeout()
      同期 (ブロッキング) メソッド署名を使用して、HTTP サービスメソッドからのレスポンスをブロックする設定された時間を返します。

      デフォルトでは設定されていません。この場合の動作は、基礎となる HTTP クライアントの接続およびリクエストのタイムアウト設定に依存します。基礎となる HTTP クライアントでタイムアウト値を直接構成することをお勧めします。これにより、そのような設定をより詳細に制御できるようになります。

    • exchangeForMono

      reactor.core.publisher.Mono<VoidSE> exchangeForMono(HttpRequestValues requestValues)
      指定されたリクエストを実行し、レスポンスコンテンツがある場合はそれを解放します。
      パラメーター:
      requestValues - 実行するリクエスト
      戻り値:
      リクエストが完全に実行され、レスポンスの内容が解放されると完了する Mono
    • exchangeForHeadersMono

      reactor.core.publisher.Mono<HttpHeaders> exchangeForHeadersMono(HttpRequestValues requestValues)
      指定されたリクエストを実行し、レスポンスコンテンツを解放し、レスポンスヘッダーを返します。
      パラメーター:
      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) のバリアント。