public class ReactiveAdapterRegistry extends ObjectSE
Publisher
を CompletableFuture
、RxJava Observable
などのさまざまな非同期 / リアクティブ型に適応させるためのアダプターのレジストリ。 デフォルトでは、クラスパスの可用性に応じて、アダプターは Reactor、RxJava 1、RxJava 2 型、CompletableFuture
SE、Java 9+ Flow.Publisher
に登録されます。
コンストラクターと説明 |
---|
ReactiveAdapterRegistry() レジストリを作成し、デフォルトのアダプターを自動登録します。 |
修飾子と型 | メソッドと説明 |
---|---|
ReactiveAdapter | getAdapter(ClassSE<?> reactiveType) 指定されたリアクティブ型のアダプターを取得します。 |
ReactiveAdapter | getAdapter(ClassSE<?> reactiveType, ObjectSE source) 指定されたリアクティブ型のアダプターを取得します。 |
static ReactiveAdapterRegistry | getSharedInstance() 共有のデフォルト ReactiveAdapterRegistry インスタンスを返し、必要に応じて遅延ビルドします。 |
boolean | hasAdapters() レジストリにアダプターがあるかどうか。これは、Reactor、RxJava 2、または RxJava 1(+ RxJava Reactive Streams ブリッジ)のいずれかがクラスパスに存在する場合に該当します。 |
void | registerReactiveType(ReactiveTypeDescriptor descriptor, FunctionSE<ObjectSE,org.reactivestreams.Publisher<?>> toAdapter, FunctionSE<org.reactivestreams.Publisher<?>,ObjectSE> fromAdapter) Reactive Streams Publisher との間で適応する関数とともに、リアクティブ型を登録します。 |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
public ReactiveAdapterRegistry()
getSharedInstance()
public boolean hasAdapters()
public void registerReactiveType(ReactiveTypeDescriptor descriptor, FunctionSE<ObjectSE,org.reactivestreams.Publisher<?>> toAdapter, FunctionSE<org.reactivestreams.Publisher<?>,ObjectSE> fromAdapter)
Publisher
との間で適応する関数とともに、リアクティブ型を登録します。関数の引数は、それらの入力が null
でも Optional
SE でもないと想定しています。@Nullable public ReactiveAdapter getAdapter(ClassSE<?> reactiveType)
null
@Nullable public ReactiveAdapter getAdapter(@Nullable ClassSE<?> reactiveType, @Nullable ObjectSE source)
reactiveType
- リアクティブ型 (具体的なソースオブジェクトが指定されている場合、null
になる可能性があります)source
- リアクティブ型のインスタンス (つまり、適応する ; リアクティブ型が指定されている場合、null
になる場合があります)null
public static ReactiveAdapterRegistry getSharedInstance()
ReactiveAdapterRegistry
インスタンスを返し、必要に応じて遅延ビルドします。 注意 : カスタマイズを目的として、長期間有効な事前構成済みの ReactiveAdapterRegistry
インスタンスを渡すことを強くお勧めします。このアクセサーは、提供されていない場合にデフォルトのインスタンスにフォールバックしたいコードパスのフォールバックとしてのみ意図されています。
ReactiveAdapterRegistry
インスタンス