Package org.springframework.cloud.function.core

Interface Summary

Interface	Description
FluxWrapper<T>
FunctionFactoryMetadata<F>
Isolated

Class Summary

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.