- Type Parameters:
I
- input type of target function
O
- output type of target function
- All Implemented Interfaces:
- Function<reactor.core.publisher.Flux<I>,reactor.core.publisher.Flux<O>>, FluxWrapper<Function<reactor.core.publisher.Flux<I>,reactor.core.publisher.Flux<O>>>
public class FluxedFunction<I,O>
extends WrappedFunction<I,O,reactor.core.publisher.Flux<I>,reactor.core.publisher.Flux<O>,Function<reactor.core.publisher.Flux<I>,reactor.core.publisher.Flux<O>>>
Function
implementation that wraps a target Function so that the target's
simple input and output types will be wrapped as
Flux
instances.
- Since:
- 2.0.1
- Author:
- Oleg Zhurakousky