Modifier and Type | Class and Description |
---|---|
class |
FluxConsumer<I>
Wrapper for a
Consumer implementation that converts a non-reactive
consumer into a reactive function (Function<Flux<?>, Mono<?>> ). |
class |
FluxedConsumer<I>
Wrapper for a
Consumer implementation that converts a reactive consumer into a
reactive function (Function<Flux<?>, Mono<?>> ). |
class |
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. |
class |
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. |
class |
FluxSupplier<T>
Supplier implementation that wraps a target Supplier so that the target's
simple output type will be wrapped in a Flux instance. |
class |
FluxToMonoFunction<I,O>
Wrapper to mark function
Function<Flux<?>, Mono<?>> . |
class |
MonoSupplier<T>
Supplier implementation that wraps a target Supplier so that the target's
simple output type will be wrapped in a Mono instance. |
class |
MonoToFluxFunction<I,O>
Marker wrapper for target Function<Mono, Flux>.
|
class |
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 © 2021 Pivotal Software, Inc.. All rights reserved.