インターフェース RSocketRequester
- すべてのスーパーインターフェース:
reactor.core.Disposable
public interface RSocketRequester
extends reactor.core.Disposable
ルーティングやその他のメタデータを準備するメソッドとともに、入力および出力用の高レベルのオブジェクトを受け入れて返す流れるような API を備えた送信
RSocket
の薄いラッパー。- 導入:
- 5.2
- 作成者:
- Rossen Stoyanchev, Brian Clozel
ネストされたクラスのサマリー
修飾子と型インターフェース説明static interface
サーバーに接続してリクエスターを作成するビルダー。static interface
追加の複合メタデータエントリを提供するための仕様。static interface
RSocket リクエストの入力を宣言する仕様。static interface
RSocket リクエストの予想される出力を宣言するための仕様。インターフェース reactor.core.Disposable から継承されたネストクラス / インターフェース
reactor.core.Disposable.Composite, reactor.core.Disposable.Swap
メソッドのサマリー
修飾子と型メソッド説明static RSocketRequester.Builder
builder()
RSocket サーバーに接続して、クライアントRSocketRequester
を作成するビルダーを取得します。接続時に基になる RSocket に対して選択されたデータMimeType
を返します。default void
dispose()
基盤となるトランスポートからの接続を閉じてサブスクライバーに通知するために、基盤となるrsocketClient()
で同じものに委譲するショートカットメソッド。default boolean
基礎となるrsocketClient()
で同じものに委譲するショートカットメソッド。指定されたメタデータ値を使用して新しいリクエストの指定を開始します。これは、具体的な値、またはReactiveAdapterRegistry
を介してPublisher
に適合できる単一の値の任意のプロデューサーにすることができます。接続時に基になる RSocket に対して選択されたメタデータMimeType
を返します。リモートハンドラーへの指定されたルートで新しいリクエストを指定し始めます。rsocket()
リクエスターがwrap(RSocket, MimeType, MimeType, RSocketStrategies)
またはRSocketRequester
ビルダーの(非推奨の)接続メソッドの 1 つを介して「ライブ」RSocket で作成された場合は、基になるRSocket
を返します。それ以外の場合は、null
を返します。でリクエストを行うために使用される基礎となるRSocketClient
を返します。設定されたRSocketStrategies
を返します。static RSocketRequester
wrap
(RSocket rsocket, MimeType dataMimeType, MimeType metadataMimeType, RSocketStrategies strategies) 既存のRSocket
をラップします。
メソッドの詳細
rsocketClient
RSocketClient rsocketClient()でリクエストを行うために使用される基礎となるRSocketClient
を返します。- 導入:
- 5.3
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
リモートハンドラーへの指定されたルートで新しいリクエストを指定し始めます。ルートは、プレースホルダーを含むテンプレートにすることができます。
"flight.{code}"
。この場合、提供されたルート変数はtoString()
を介してフォーマットされ、テンプレートに展開されます。フォーマットされた変数に "." が含まれている場合レスポンダによってセパレータとして扱われないように、エスケープシーケンス "%2E" に置き換えられます。複合メタデータを使用するように接続が設定されている場合、ルートは
"message/x.rsocket.routing.v0"
としてエンコードされます。それ以外の場合、ルートは接続の MIME 型に従ってエンコードされます。- パラメーター:
route
- リモートハンドラーマッピングを表すルートrouteVars
- ルートテンプレートに展開される変数- 戻り値:
- リクエストをさらに定義して実行するための仕様
metadata
指定されたメタデータ値を使用して新しいリクエストの指定を開始します。これは、具体的な値、または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
RSocket サーバーに接続して、クライアントRSocketRequester
を作成するビルダーを取得します。wrap
static RSocketRequester wrap(RSocket rsocket, MimeType dataMimeType, MimeType metadataMimeType, RSocketStrategies strategies)