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, waitSE
public ReactiveAdapterRegistry()
getSharedInstance()
public boolean hasAdapters()
public void registerReactiveType(ReactiveTypeDescriptor descriptor, FunctionSE<ObjectSE,Publisher<?>> toAdapter, FunctionSE<Publisher<?>,ObjectSE> fromAdapter)
Publisher
に適合したり、Reactive Streams Publisher
から適合したりする関数とともにリアクティブ型を登録します。関数の引数は、入力が null
でも Optional
SE でもないことを前提としています。このバリアントは、既存のアダプターの後に新しいアダプターを登録します。以前のアダプターが特定の型に登録されていない場合は、正確なリアクティブ型と照合され、以前のアダプターに以前に割り当て可能な型がなかった場合は、2 番目のパスで割り当て可能性について照合されます。
public void registerReactiveTypeOverride(ReactiveTypeDescriptor descriptor, FunctionSE<ObjectSE,Publisher<?>> toAdapter, FunctionSE<Publisher<?>,ObjectSE> fromAdapter)
Publisher
に適合したり、Reactive Streams 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
インスタンス