public interface RSocketRequester
extends reactor.core.Disposable
RSocket
の薄いラッパー。修飾子と型 | インターフェースと説明 |
---|---|
static interface | RSocketRequester.Builder サーバーに接続してリクエスターを作成するビルダー。 |
static interface | RSocketRequester.MetadataSpec<S extends RSocketRequester.MetadataSpec<S>> 追加の複合メタデータエントリを提供するための仕様。 |
static interface | RSocketRequester.RequestSpec RSocket リクエストの入力を宣言する仕様。 |
static interface | RSocketRequester.RetrieveSpec RSocket リクエストの予想される出力を宣言するための仕様。 |
修飾子と型 | メソッドと説明 |
---|---|
static RSocketRequester.Builder | builder() RSocket サーバーに接続して、クライアント RSocketRequester を作成するビルダーを取得します。 |
MimeType | dataMimeType() 接続時に基になる RSocket に対して選択されたデータ MimeType を返します。 |
default void | dispose() 基盤となるトランスポートからの接続を閉じてサブスクライバーに通知するために、基盤となる rsocketClient() で同じものに委譲するショートカットメソッド。 |
default boolean | isDisposed() 基礎となる rsocketClient() で同じものに委譲するショートカットメソッド。 |
RSocketRequester.RequestSpec | metadata(ObjectSE metadata, MimeType mimeType) 指定されたメタデータ値を使用して新しいリクエストの指定を開始します。これは、具体的な値、または ReactiveAdapterRegistry を介して Publisher に適合できる単一の値の任意のプロデューサーにすることができます。 |
MimeType | metadataMimeType() 接続時に基になる RSocket に対して選択されたメタデータ MimeType を返します。 |
RSocketRequester.RequestSpec | route(StringSE route, ObjectSE... routeVars) リモートハンドラーへの指定されたルートで新しいリクエストを指定し始めます。 |
RSocket | rsocket() リクエスターが wrap(RSocket, MimeType, MimeType, RSocketStrategies) または RSocketRequester ビルダーの(非推奨の)接続メソッドの 1 つを介して「ライブ」RSocket で作成された場合は、基になる RSocket を返します。それ以外の場合は、null を返します。 |
RSocketClient | rsocketClient() でリクエストを行うために使用される基礎となる RSocketClient を返します。 |
static RSocketRequester | wrap(RSocket rsocket, MimeType dataMimeType, MimeType metadataMimeType, RSocketStrategies strategies) 既存の RSocket をラップします。 |
RSocketClient rsocketClient()
RSocketClient
を返します。@Nullable 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
のままにすることができます。default void dispose()
rsocketClient()
で同じものに委譲するショートカットメソッド。reactor.core.Disposable
の dispose
default boolean isDisposed()
rsocketClient()
で同じものに委譲するショートカットメソッド。reactor.core.Disposable
の isDisposed
static RSocketRequester.Builder builder()
RSocketRequester
を作成するビルダーを取得します。static RSocketRequester wrap(RSocket rsocket, MimeType dataMimeType, MimeType metadataMimeType, RSocketStrategies strategies)