パッケージ org.springframework.core

クラス ReactiveAdapterRegistry

java.lang.ObjectSE
org.springframework.core.ReactiveAdapterRegistry
public class ReactiveAdapterRegistry extends ObjectSE
Reactive Streams Publisher を、CompletableFuture、RxJava Flowable などのさまざまな非同期 / リアクティブ型との間で適合させるためのアダプターのレジストリ。

デフォルトでは、クラスパスの可用性に応じて、アダプターは Reactor、RxJava 3、CompletableFutureSE、Flow.Publisher、Kotlin コルーチンの Deferred と Flow に登録されます。

導入:
5.0
作成者:
Rossen Stoyanchev, Sebastien Deleuze, Juergen Hoeller

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

    • ReactiveAdapterRegistry

      public ReactiveAdapterRegistry()
      レジストリを作成し、デフォルトのアダプターを自動登録します。
      関連事項:

  • 方法の詳細

    • hasAdapters

      public boolean hasAdapters()
      レジストリにアダプターがあるかどうか。

    • registerReactiveType

      public void registerReactiveType(ReactiveTypeDescriptor descriptor, FunctionSE<ObjectSE,Publisher<?>> toAdapter, FunctionSE<Publisher<?>,ObjectSE> fromAdapter)
      Reactive Streams Publisher に適合したり、Reactive Streams Publisher から適合したりする関数とともにリアクティブ型を登録します。関数の引数は、入力が null でも OptionalSE でもないことを前提としています。

    • getAdapter

      @Nullable public ReactiveAdapter getAdapter(ClassSE<?> reactiveType)
      指定されたリアクティブ型のアダプターを取得します。
      戻り値:
      対応するアダプター、または使用可能なものがなければ null 

    • getAdapter

      @Nullable public ReactiveAdapter getAdapter(@Nullable ClassSE<?> reactiveType, @Nullable ObjectSE source)
      指定されたリアクティブ型のアダプターを取得します。または、「ソース」オブジェクトが指定されている場合は、実際の型が代わりに使用されます。
      パラメーター:
      reactiveType - リアクティブ型 (具体的なソースオブジェクトが指定されている場合、null になる可能性があります)
      source - リアクティブ型のインスタンス (つまり、適応する ; リアクティブ型が指定されている場合、null になる場合があります)
      戻り値:
      対応するアダプター、または使用可能なものがなければ null 

    • getSharedInstance

      public static ReactiveAdapterRegistry getSharedInstance()
      共有のデフォルト ReactiveAdapterRegistry インスタンスを返し、必要に応じて遅延ビルドします。

      注意 : カスタマイズを目的として、長期間有効な事前構成済みの ReactiveAdapterRegistry インスタンスを渡すことを強くお勧めします。このアクセサーは、提供されていない場合にデフォルトのインスタンスにフォールバックしたいコードパスのフォールバックとしてのみ意図されています。

      戻り値:
      共有された ReactiveAdapterRegistry インスタンス
      導入:
      5.0.2