メソッドの詳細

• 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 を参照してください。