public class ReactiveAdapterRegistry extends Object
Flux
and Mono
.
By default there are adapters for CompletableFuture
, RxJava 1, and
also for a any Reactive Streams Publisher
. Additional adapters can be
registered via registerFluxAdapter(java.lang.Class<?>, java.util.function.Function<java.lang.Object, reactor.core.publisher.Flux<?>>, java.util.function.Function<reactor.core.publisher.Flux<?>, java.lang.Object>)
and registerMonoAdapter(java.lang.Class<?>, java.util.function.Function<java.lang.Object, reactor.core.publisher.Mono<?>>, java.util.function.Function<reactor.core.publisher.Mono<?>, java.lang.Object>, org.springframework.core.ReactiveAdapter.Descriptor)
.
Constructor and Description |
---|
ReactiveAdapterRegistry()
Create a registry and auto-register default adapters.
|
Modifier and Type | Method and Description |
---|---|
ReactiveAdapter |
getAdapterFrom(Class<?> adapteeType)
Get the adapter for the given adaptee type to adapt from.
|
ReactiveAdapter |
getAdapterFrom(Class<?> adapteeType,
Object adaptee)
Get the adapter for the given adaptee type to adapt from.
|
ReactiveAdapter |
getAdapterTo(Class<?> adapteeType)
Get the adapter for the given adaptee type to adapt to.
|
ReactiveAdapter |
getAdapterTo(Class<?> adapteeType,
Object adaptee)
Get the adapter for the given adaptee type to adapt to.
|
void |
registerFluxAdapter(Class<?> adapteeType,
Function<Object,reactor.core.publisher.Flux<?>> toAdapter,
Function<reactor.core.publisher.Flux<?>,Object> fromAdapter)
Register an adapter for adapting to and from a
Flux . |
void |
registerMonoAdapter(Class<?> adapteeType,
Function<Object,reactor.core.publisher.Mono<?>> toAdapter,
Function<reactor.core.publisher.Mono<?>,Object> fromAdapter,
ReactiveAdapter.Descriptor descriptor)
Register an adapter for adapting to and from a
Mono . |
public ReactiveAdapterRegistry()
public void registerMonoAdapter(Class<?> adapteeType, Function<Object,reactor.core.publisher.Mono<?>> toAdapter, Function<reactor.core.publisher.Mono<?>,Object> fromAdapter, ReactiveAdapter.Descriptor descriptor)
Mono
.
The provided functions can assume that input will never be null
and also that any Optional
wrapper is unwrapped.
public void registerFluxAdapter(Class<?> adapteeType, Function<Object,reactor.core.publisher.Flux<?>> toAdapter, Function<reactor.core.publisher.Flux<?>,Object> fromAdapter)
Flux
.
The provided functions can assume that input will never be null
and also that any Optional
wrapper is unwrapped.
public ReactiveAdapter getAdapterFrom(Class<?> adapteeType)
public ReactiveAdapter getAdapterFrom(Class<?> adapteeType, Object adaptee)
null
its actual type is used to check.public ReactiveAdapter getAdapterTo(Class<?> adapteeType)
public ReactiveAdapter getAdapterTo(Class<?> adapteeType, Object adaptee)
null
its actual type is used to check.