インターフェース RSocketRequester.RetrieveSpec

メソッドの詳細

• send

  reactor.core.publisher.Mono<VoidSE> send()

  提供されたデータとメタデータを送信する fireAndForget を実行します。

  戻り値:

  ペイロードが正常に送信されたかどうかを示す完了。ただし、これは一方向の送信であり、リモート側で偶数が処理されたかどうかまたはどのように処理されたかは示されません。

• retrieveMono

  <T> reactor.core.publisher.Mono<T> retrieveMono(ClassSE<T> dataType)

  requestResponse 交換を実行します。

  戻り値の型が Mono<Void> の場合、すべてのデータが消費された後で Mono が完了します。

  注意 : 多対 1 の RSocket 相互作用がないため、リクエストペイロードが複数値の Publisher である場合、このメソッドはエラーを発生させます。

  型パラメーター:

  T - 予期されるデータ型のパラメーター

  パラメーター:

  dataType - レスポンスに期待されるデータ型

  戻り値:

  デコードされたレスポンス

• retrieveMono

  <T> reactor.core.publisher.Mono<T> retrieveMono(ParameterizedTypeReference<T> dataTypeRef)

  dataType にジェネリクス型が必要な場合の retrieveMono(Class) のバリアント。ParameterizedTypeReference を参照してください。

• retrieveFlux

  <T> reactor.core.publisher.Flux<T> retrieveFlux(ClassSE<T> dataType)

  リクエスト入力が単一ペイロードであるか複数ペイロードであるかに応じて、requestStream または requestChannel 交換を実行します。

  戻り値の型が Flux<Void> の場合、すべてのデータが消費された後で Flux が完了します。

  型パラメーター:

  T - 予想される値の型をパラメーター化する

  パラメーター:

  dataType - レスポンスの値に期待される型

  戻り値:

  デコードされたレスポンス

• retrieveFlux

  <T> reactor.core.publisher.Flux<T> retrieveFlux(ParameterizedTypeReference<T> dataTypeRef)

  dataType にジェネリクス型が必要な場合の retrieveFlux(Class) のバリアント。ParameterizedTypeReference を参照してください。