public class ReactiveAdapterRegistry extends ObjectSE
Publisher を CompletableFuture、RxJava Flowable などのさまざまな非同期 / リアクティブ型に / から適応させるアダプターのレジストリ。これは、Spring の Reactor Mono/Flux サポートを補完するように設計されていますが、Reactor なしでも使用できます。org.reactivestreams ブリッジ専用。 デフォルトでは、クラスパスの可用性に応じて、アダプターは Reactor (CompletableFuture および Flow.Publisher アダプターを含む)、RxJava 3、Kotlin コルーチンの Deferred (Reactor 経由でブリッジ)、および SmallRye Mutiny 1.x に登録されます。
注意 : Spring Framework 5.3.11 の時点で、RxJava 1.x および 2.x のサポートは非推奨となり、RxJava 3 が優先されます。
| 修飾子と型 | クラスと説明 |
|---|---|
static class | ReactiveAdapterRegistry.SpringCoreBlockHoundIntegration spring-core クラスの BlockHoundIntegration。 |
| コンストラクターと説明 |
|---|
ReactiveAdapterRegistry() レジストリを作成し、デフォルトのアダプターを自動登録します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
ReactiveAdapter | getAdapter(ClassSE<?> reactiveType) 指定されたリアクティブ型のアダプターを取得します。 |
ReactiveAdapter | getAdapter(ClassSE<?> reactiveType, ObjectSE source) 指定されたリアクティブ型のアダプターを取得します。 |
static ReactiveAdapterRegistry | getSharedInstance() 共有のデフォルト ReactiveAdapterRegistry インスタンスを返し、必要に応じて遅延ビルドします。 |
boolean | hasAdapters() レジストリにアダプターがあるかどうか。 |
void | registerReactiveType(ReactiveTypeDescriptor descriptor, FunctionSE<ObjectSE, Publisher<?>> toAdapter, FunctionSE<Publisher<?>,ObjectSE> fromAdapter) |
void | registerReactiveTypeOverride(ReactiveTypeDescriptor descriptor, FunctionSE<ObjectSE, Publisher<?>> toAdapter, FunctionSE<Publisher<?>,ObjectSE> fromAdapter) |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic ReactiveAdapterRegistry()
getSharedInstance()public boolean hasAdapters()
public void registerReactiveType(ReactiveTypeDescriptor descriptor, FunctionSE<ObjectSE,Publisher<?>> toAdapter, FunctionSE<Publisher<?>,ObjectSE> fromAdapter)
Publisher に適合したり、Reactive Streams Publisher から適合したりする関数とともにリアクティブ型を登録します。関数の引数は、入力が null でも OptionalSE でもないことを前提としています。このバリアントは、既存のアダプターの後に新しいアダプターを登録します。以前のアダプターが特定の型に登録されていない場合は、正確なリアクティブ型と照合され、以前のアダプターに以前に割り当て可能な型がなかった場合は、2 番目のパスで割り当て可能性について照合されます。
public void registerReactiveTypeOverride(ReactiveTypeDescriptor descriptor, FunctionSE<ObjectSE,Publisher<?>> toAdapter, FunctionSE<Publisher<?>,ObjectSE> fromAdapter)
Publisher に適合したり、Reactive Streams Publisher から適合したりする関数とともにリアクティブ型を登録します。関数の引数は、入力が null でも OptionalSE でもないことを前提としています。このバリアントは、最初に新しいアダプターを登録し、同じリアクティブ型に対して以前に登録されたアダプターを効果的にオーバーライドします。これにより、既存のアダプター、特にデフォルトのアダプターをオーバーライドできます。
割り当て可能性が新しいアダプターと一致する前に、特定の型の既存のアダプターが一致することに注意してください。既存のすべての一致をオーバーライドするには、サブ型の割り当て可能性の一致に依存せず、特定の型ごとに新しいリアクティブ型 アダプターを登録する必要があります。
@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 インスタンス