パッケージ org.springframework.core

クラス ReactiveAdapter

java.lang.ObjectSE
org.springframework.core.ReactiveAdapter
public class ReactiveAdapter extends ObjectSE
CompletableFuture、RxJava Observable などの非同期 / リアクティブ型との間の Reactive Streams Publisher 用アダプター。

アダプターは通常、ReactiveAdapterRegistry を介して取得されます。

導入:
5.0
作成者:
Rossen Stoyanchev

  • コンストラクターの詳細

    • ReactiveAdapter

      public ReactiveAdapter(ReactiveTypeDescriptor descriptor, FunctionSE<ObjectSE,Publisher<?>> toPublisherFunction, FunctionSE<Publisher<?>,ObjectSE> fromPublisherFunction)
      ターゲットのリアクティブ型または非同期型を Reactive Streams パブリッシャーとの間で変換する機能を持つアダプターのコンストラクター。
      パラメーター:
      descriptor - リアクティブ型記述子
      toPublisherFunction - パブリッシャーへのアダプター
      fromPublisherFunction - パブリッシャーからのアダプター

  • メソッドの詳細

    • getDescriptor

      public ReactiveTypeDescriptor getDescriptor()
      アダプターのリアクティブ型の記述子を返します。

    • getReactiveType

      public ClassSE<?> getReactiveType()
      getDescriptor().getReactiveType() のショートカット。

    • isMultiValue

      public boolean isMultiValue()
      getDescriptor().isMultiValue() のショートカット。

    • isNoValue

      public boolean isNoValue()
      getDescriptor().isNoValue() のショートカット。

    • supportsEmpty

      public boolean supportsEmpty()
      getDescriptor().supportsEmpty() のショートカット。

    • toPublisher

      public <T> Publisher<T> toPublisher(@Nullable ObjectSE source)
      指定されたインスタンスを Reactive Streams Publisher に適合させます。
      パラメーター:
      source - 適応するソースオブジェクト。指定されたオブジェクトが null の場合、ReactiveTypeDescriptor.getEmptyValue() が使用されます。
      戻り値:
      適応を表すパブリッシャー

    • fromPublisher

      public ObjectSE fromPublisher(Publisher<?> publisher)
      指定された Reactive Streams パブリッシャーから適応します。
      パラメーター:
      publisher - 適応するパブリッシャー
      戻り値:
      適応パブリッシャーを表すリアクティブ型インスタンス