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