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.