- Type Parameters:
T
- type of Flux
input of the target function
R
- type of Mono
output of the target function
- All Implemented Interfaces:
- Function<reactor.core.publisher.Flux<I>,reactor.core.publisher.Mono<O>>, FluxWrapper<Function<reactor.core.publisher.Flux<I>,reactor.core.publisher.Mono<O>>>
public class FluxToMonoFunction<I,O>
extends Object
implements Function<reactor.core.publisher.Flux<I>,reactor.core.publisher.Mono<O>>, FluxWrapper<Function<reactor.core.publisher.Flux<I>,reactor.core.publisher.Mono<O>>>
Marker wrapper for target Function<Flux, Mono>
- Since:
- 2.0
- Author:
- Oleg Zhurakousky