メソッドの詳細

• dataMimeType

  RSocketRequester.Builder dataMimeType(@Nullable
                                        MimeType mimeType)

  接続全体に適用される SETUP フレームで指定するペイロードデータ MimeType を構成します。

  設定されていない場合、これは最初の non-default Decoder の MimeType、または最初のデコーダーの MimeType に初期化されます。

• metadataMimeType

  RSocketRequester.Builder metadataMimeType(MimeType mimeType)

  ペイロードメタデータ MimeType を構成して、接続全体に適用される SETUP フレームで指定します。

  デフォルトでは、これは "message/x.rsocket.composite-metadata.v0" に設定されています。この場合、ルートが指定されている場合、"message/x.rsocket.routing.v0" 複合メタデータエントリとしてエンコードされます。これが他の MimeType に設定されている場合、ルートの MimeType が提供されていると想定されます。

• setupData

  RSocketRequester.Builder setupData(ObjectSE data)

  設定ペイロードのデータを設定します。データは、構成された dataMimeType(MimeType) に従ってエンコードされます。データは具体的な値、または ReactiveAdapterRegistry を介して Publisher に適合できる単一の値のプロデューサーです。

  デフォルトでは、これは設定されていません。

• setupRoute

  RSocketRequester.Builder setupRoute(StringSE route,
                                      ObjectSE... routeVars)

  セットアップペイロードのルートを設定します。ルートのフォーマットとエンコードのルールは、RSocketRequester.route(String, Object...) で説明されているリクエストルートのルールと同じです。

  デフォルトでは、これは設定されていません。

• setupMetadata

  RSocketRequester.Builder setupMetadata(ObjectSE value,
                                         @Nullable
                                         MimeType mimeType)

  メタデータエントリをセットアップペイロードに追加します。これが複数回呼び出される場合、または setupRoute(String, Object...) に加えて呼び出される場合は、複合メタデータを使用する必要があります。メタデータ値は、具体的な値、または ReactiveAdapterRegistry を介して Publisher に適応できる単一の値のプロデューサーです。

• rsocketStrategies

  RSocketRequester.Builder rsocketStrategies(@Nullable
                                             RSocketStrategies strategies)

  使用する RSocketStrategies を提供します。

  これはデフォルト設定を変更できますが、それでも rsocketStrategies(Consumer) を介してさらにカスタマイズできます。設定しない場合、デフォルトは RSocketStrategies.builder() から取得されます。

  パラメーター:

  strategies - 使用する戦略

• rsocketStrategies

  RSocketRequester.Builder rsocketStrategies(ConsumerSE<RSocketStrategies.Builder> configurer)

  RSocketStrategies をカスタマイズします。

  RSocketStrategies をさらにカスタマイズしたり、set の場合は変更したり、RSocketStrategies.builder() のデフォルトから開始したりできます。}。

• rsocketConnector

  RSocketRequester.Builder rsocketConnector(RSocketConnectorConfigurer configurer)

  RSocketConnector を直接構成するためのコールバック。

  • データとメタデータの MIME 型は、RSocketConnector で直接設定することはできず、オーバーライドされます。代わりに、このビルダーのショートカット dataMimeType(MimeType) および metadataMimeType(MimeType) を使用してください。
  • また、フレームデコーダーを直接設定することはできず、構成された DataBufferFactory と一致するように設定されます。
  • setupPayload の場合、このビルダーのメソッドを使用して、ルート、その他のメタデータ、データをエンコードするオブジェクト値として指定することを検討してください。
  • クライアント側の応答を構成するには、RSocketMessageHandler.responder(RSocketStrategies, Object...) を参照してください。

  導入:

  5.2.6

• rsocketFactory

  @DeprecatedSE
  RSocketRequester.Builder rsocketFactory(ClientRSocketFactoryConfigurer configurer)

  RSocket 1.0 RC7 での RSocketFactory.ClientRSocketFactory の廃止に伴い、5.2.6 では 非推奨です。rsocketConnector(RSocketConnectorConfigurer) を使用してください。
  ClientRSocketFactory を直接構成するためのコールバック。

  • データとメタデータの MIME 型は、ClientRSocketFactory で直接設定することはできず、オーバーライドされます。代わりに、このビルダーのショートカット dataMimeType(MimeType) および metadataMimeType(MimeType) を使用してください。
  • また、フレームデコーダーを直接設定することはできず、構成された DataBufferFactory と一致するように設定されます。
  • setupPayload の場合、このビルダーのメソッドを使用して、ルート、その他のメタデータ、データをエンコードするオブジェクト値として指定することを検討してください。
  • クライアント側の応答を構成するには、RSocketMessageHandler.clientResponder(RSocketStrategies, Object...) を参照してください。

• apply

  RSocketRequester.Builder apply(ConsumerSE<RSocketRequester.Builder> configurer)

  Consumer を介してこのビルダーを構成します。これにより、Spring Security などのライブラリは、関連する一連のカスタマイズを適用するためのショートカットを提供できます。

  パラメーター:

  configurer - 適用するコンフィギュレーター

• connectTcp

  reactor.core.publisher.Mono<RSocketRequester> connectTcp(StringSE host,
                                                           int port)

  TCP 経由でサーバーに接続します。

  パラメーター:

  host - サーバーホスト

  port - サーバーポート

  戻り値:

  接続用の RSocketRequester 

  関連事項:

  TcpClientTransport

• connectWebSocket

  reactor.core.publisher.Mono<RSocketRequester> connectWebSocket(URISE uri)

  WebSocket 経由でサーバーに接続します。

  パラメーター:

  uri - RSocket サーバーのエンドポイント URI

  戻り値:

  接続用の RSocketRequester 

  関連事項:

  WebsocketClientTransport

• connect

  reactor.core.publisher.Mono<RSocketRequester> connect(io.rsocket.transport.ClientTransport transport)

  指定された ClientTransport でサーバーに接続します。

  パラメーター:

  transport - 使用するクライアントトランスポート

  戻り値:

  接続用の RSocketRequester