public interface RSocketRequesterRSocket の薄いラッパー。ルーティングやその他のメタデータを準備するためのメソッドとともに、入力および出力用のより高レベルのオブジェクトを受け入れて返します。| 修飾子と型 | インターフェースと説明 |
|---|---|
static interface | RSocketRequester.Builder サーバーに接続してリクエスターを作成するビルダー。 |
static interface | RSocketRequester.MetadataSpec<S extends RSocketRequester.MetadataSpec<S>> 追加の複合メタデータエントリを提供するための仕様。 |
static interface | RSocketRequester.RequestSpecRSocket リクエストの入力を宣言する仕様。 |
static interface | RSocketRequester.RetrieveSpecRSocket リクエストの予想される出力を宣言するための仕様。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
static RSocketRequester.Builder | builder()RSocket サーバーに接続して、クライアント RSocketRequester を作成するビルダーを取得します。 |
MimeType | dataMimeType() 接続時に基になる RSocket に対して選択されたデータ MimeType を返します。 |
RSocketRequester.RequestSpec | metadata(ObjectSE metadata, MimeType mimeType) 特定のメタデータ値、または ReactiveAdapterRegistry を介して Publisher に適合させることができる単一の値の任意のプロデューサーである可能性がある、指定されたメタデータ値で新しいリクエストを指定し始めます。 |
MimeType | metadataMimeType() 接続時に基になる RSocket に対して選択されたメタデータ MimeType を返します。 |
RSocketRequester.RequestSpec | route(StringSE route, ObjectSE... routeVars) リモートハンドラーへの指定されたルートで新しいリクエストを指定し始めます。 |
io.rsocket.RSocket | rsocket() リクエスターが wrap(RSocket, MimeType, MimeType, RSocketStrategies) または RSocketRequester ビルダーの（非推奨の）接続メソッドの 1 つを介して「ライブ」RSocket で作成された場合は、基になる RSocket を返すか、それ以外の場合は null を返します。 |
io.rsocket.core.RSocketClient | rsocketClient() でリクエストを行うために使用される基になる RSocketClient を返します。 |
static RSocketRequester | wrap(io.rsocket.RSocket rsocket, MimeType dataMimeType, MimeType metadataMimeType, RSocketStrategies strategies) 既存の RSocket をラップします。 |
io.rsocket.core.RSocketClient rsocketClient()
RSocketClient を返します。@Nullable io.rsocket.RSocket rsocket()
wrap(RSocket, MimeType, MimeType, RSocketStrategies) または RSocketRequester ビルダーの（非推奨の）接続メソッドの 1 つを介して「ライブ」RSocket で作成された場合は、基になる RSocket を返すか、それ以外の場合は null を返します。MimeType dataMimeType()
MimeType を返します。これはクライアント側では RSocketRequester.Builder.dataMimeType(MimeType) を介して構成され、サーバー側では ConnectionSetupPayload から取得されます。MimeType metadataMimeType()
MimeType を返します。これはクライアント側では RSocketRequester.Builder.metadataMimeType(MimeType) を介して構成され、サーバー側では ConnectionSetupPayload から取得されます。RSocketRequester.RequestSpec route(StringSE route, ObjectSE... routeVars)
ルートは、プレースホルダーを含むテンプレートにすることができます。"flight.{code}"。この場合、提供されたルート変数は toString() を介してフォーマットされ、テンプレートに展開されます。フォーマットされた変数に "." が含まれている場合レスポンダによってセパレータとして扱われないように、エスケープシーケンス "%2E" に置き換えられます。
接続が複合メタデータを使用するように設定されている場合、ルートは "message/x.rsocket.routing.v0" としてエンコードされます。それ以外の場合、ルートは接続の MIME 型に従ってエンコードされます。
route - リモートハンドラーマッピングを表すルート routeVars - ルートテンプレートに展開される変数 RSocketRequester.RequestSpec metadata(ObjectSE metadata, @Nullable MimeType mimeType)
ReactiveAdapterRegistry を介して Publisher に適合させることができる単一の値の任意のプロデューサーである可能性がある、指定されたメタデータ値で新しいリクエストを指定し始めます。metadata - エンコードするメタデータ値 mimeType - メタデータを説明する MIME 型。これは、複合メタデータを使用した接続に必要です。それ以外の場合、値は接続の MIME 型に従ってエンコードされ、この引数は null のままにすることができます。static RSocketRequester.Builder builder()
RSocketRequester を作成するビルダーを取得します。static RSocketRequester wrap(io.rsocket.RSocket rsocket, MimeType dataMimeType, MimeType metadataMimeType, RSocketStrategies strategies)
RSocket をラップします。通常、内部フレームワークで使用する場合は、リモート RSocket をクライアントまたはサーバーレスポンダーでラップしますが、任意の RSocket をラップするために使用することもできます。