インターフェース RSocketRequester.RetrieveSpec
- すべての既知のサブインターフェース:
RSocketRequester.RequestSpec
- 含まれているインターフェース:
- RSocketRequester
public static interface RSocketRequester.RetrieveSpec
RSocket リクエストの予想される出力を宣言するための仕様。
- 導入:
- 5.2.2
メソッドのサマリー
修飾子と型メソッド説明<T> reactor.core.publisher.Flux<T>
retrieveFlux
(ClassSE<T> dataType) リクエスト入力が単一ペイロードかマルチペイロードかに応じて、requestStream
またはrequestChannel
交換を実行します。<T> reactor.core.publisher.Flux<T>
retrieveFlux
(ParameterizedTypeReference<T> dataTypeRef) dataType にジェネリクス型が必要な場合のretrieveFlux(Class)
のバリアント。<T> reactor.core.publisher.Mono<T>
retrieveMono
(ClassSE<T> dataType) requestResponse
交換を実行します。<T> reactor.core.publisher.Mono<T>
retrieveMono
(ParameterizedTypeReference<T> dataTypeRef) dataType にジェネリクス型が必要な場合のretrieveMono(Class)
のバリアント。reactor.core.publisher.Mono<VoidSE>
send()
提供されたデータとメタデータを送信するfireAndForget
を実行します。
メソッドの詳細
send
reactor.core.publisher.Mono<VoidSE> send()提供されたデータとメタデータを送信するfireAndForget
を実行します。- 戻り値:
- ペイロードが正常に送信されたかどうかを示す完了。ただし、これは一方向の送信であり、リモート側で偶数が処理されたかどうかまたはどのように処理されたかは示されません。
retrieveMono
requestResponse
交換を実行します。戻り値の型が
Mono<Void>
の場合、すべてのデータが消費された後でMono
が完了します。注意 : 多対 1 の RSocket 相互作用がないため、リクエストペイロードが複数値の
Publisher
である場合、このメソッドはエラーを発生させます。- 型パラメーター:
T
- 予期されるデータ型のパラメーター- パラメーター:
dataType
- レスポンスに期待されるデータ型- 戻り値:
- デコードされたレスポンス
retrieveMono
dataType がジェネリクス型を持つ必要がある場合のretrieveMono(Class)
のバリアント。ParameterizedTypeReference
を参照してください。retrieveFlux
リクエスト入力が単一ペイロードかマルチペイロードかに応じて、requestStream
またはrequestChannel
交換を実行します。戻り値の型が
Flux<Void>
の場合、すべてのデータが消費された後でFlux
が完了します。- 型パラメーター:
T
- 予想される値の型をパラメーター化する- パラメーター:
dataType
- レスポンスの値に期待される型- 戻り値:
- デコードされたレスポンス
retrieveFlux
dataType がジェネリクス型を持つ必要がある場合のretrieveFlux(Class)
のバリアント。ParameterizedTypeReference
を参照してください。