Interface | Description |
---|---|
FluxWrapper<T> | |
FunctionFactoryMetadata<F> | |
Isolated |
Class | Description |
---|---|
FluxConsumer<I> |
Wrapper for a
Consumer implementation that converts a non-reactive
consumer into a reactive function (Function<Flux<?>, Mono<?>> ). |
FluxedConsumer<I> |
Wrapper for a
Consumer implementation that converts a reactive consumer into a
reactive function (Function<Flux<?>, Mono<?>> ). |
FluxedFunction<I,O> |
Function implementation that wraps a target Function so that the target's
simple input and output types will be wrapped as Flux instances. |
FluxFunction<I,O> |
Function implementation that wraps a target Function so that the target's
simple input and output types will be wrapped as Flux instances. |
FluxSupplier<T> |
Supplier implementation that wraps a target Supplier so that the target's
simple output type will be wrapped in a Flux instance. |
FluxToMonoFunction<I,O> |
Wrapper to mark function
Function<Flux<?>, Mono<?>> . |
IsolatedConsumer<T> | |
IsolatedFunction<S,T> | |
IsolatedSupplier<T> | |
MonoSupplier<T> |
Supplier implementation that wraps a target Supplier so that the target's
simple output type will be wrapped in a Mono instance. |
MonoToFluxFunction<I,O> |
Marker wrapper for target Function<Mono, Flux>.
|
WrappedFunction<I,O,IP extends org.reactivestreams.Publisher<I>,OP extends org.reactivestreams.Publisher<O>,T> |
Base class for all wrappers that represent underlying functions (user defined
suppliers, functions and/or consumers) as reactive functions.
|
Copyright © 2022 Pivotal Software, Inc.. All rights reserved.