インターフェース RSocketRequester

メソッドの詳細

• rsocketClient

  RSocketClient rsocketClient()

  でリクエストを行うために使用される基礎となる RSocketClient を返します。

  導入:

  5.3

• rsocket

  @Nullable RSocket rsocket()

  リクエスターが wrap(RSocket, MimeType, MimeType, RSocketStrategies) または RSocketRequester ビルダーの（非推奨の）接続メソッドの 1 つを介して「ライブ」RSocket で作成された場合は、基になる RSocket を返します。それ以外の場合は、null を返します。

• dataMimeType

  MimeType dataMimeType()

  接続時に、基になる RSocket 用に選択されたデータ MimeType を返します。クライアント側では、これは RSocketRequester.Builder.dataMimeType(MimeType) を介して構成されますが、サーバー側では、ConnectionSetupPayload から取得されます。

• metadataMimeType

  MimeType metadataMimeType()

  接続時に、基になる RSocket 用に選択されたメタデータ MimeType を返します。クライアント側では、これは RSocketRequester.Builder.metadataMimeType(MimeType) を介して構成されますが、サーバー側では、ConnectionSetupPayload から取得されます。

• strategies

  RSocketStrategies strategies()

  設定された RSocketStrategies を返します。

• route

  RSocketRequester.RequestSpec route(StringSE route, ObjectSE... routeVars)

  リモートハンドラーへの指定されたルートで新しいリクエストを指定し始めます。

  ルートは、プレースホルダーを含むテンプレートにすることができます。"flight.{code}" の場合、提供されたルート変数は toString() を介してフォーマットされ、テンプレートに展開されます。フォーマットされた変数に "." が含まれている場合レスポンダーが区切り文字として扱わないように、エスケープシーケンス "%2E" に置き換えられます。

  複合メタデータを使用するように接続が設定されている場合、ルートは "message/x.rsocket.routing.v0" としてエンコードされます。それ以外の場合、ルートは接続の MIME 型に従ってエンコードされます。

  パラメーター:

  route - リモートハンドラーマッピングを表すルート

  routeVars - ルートテンプレートに展開される変数

  戻り値:

  リクエストをさらに定義して実行するための仕様

• metadata

  RSocketRequester.RequestSpec metadata(ObjectSE metadata, @Nullable MimeType mimeType)

  指定されたメタデータ値を使用して新しいリクエストの指定を開始します。これは、具体的な値、または ReactiveAdapterRegistry を介して Publisher に適合できる単一の値の任意のプロデューサーにすることができます。

  パラメーター:

  metadata - エンコードするメタデータ値

  mimeType - メタデータを記述する MIME 型。これは、複合メタデータを使用した接続に必要です。それ以外の場合、値は接続の MIME 型に従ってエンコードされ、この引数は null のままにすることができます。

• dispose

  default void dispose()

  基盤となるトランスポートからの接続を閉じてサブスクライバーに通知するために、基盤となる rsocketClient() で同じものに委譲するショートカットメソッド。

  次で指定:

  インターフェース reactor.core.Disposable の dispose 

  導入:

  5.3.7

• isDisposed

  default boolean isDisposed()

  基礎となる rsocketClient() で同じものに委譲するショートカットメソッド。

  次で指定:

  インターフェース reactor.core.Disposable の isDisposed 

  導入:

  5.3.7

• builder

  static RSocketRequester.Builder builder()

  RSocket サーバーに接続して、クライアント RSocketRequester を作成するビルダーを取得します。

• wrap

  static RSocketRequester wrap(RSocket rsocket, MimeType dataMimeType, MimeType metadataMimeType, RSocketStrategies strategies)

  既存の RSocket をラップします。通常、内部フレームワークで使用する場合は、リモート RSocket をクライアントまたはサーバーレスポンダーでラップしますが、任意の RSocket をラップするために使用することもできます。