I
- type of Flux
input of the target functionO
- type of Mono
output of the target functionpublic class FluxToMonoFunction<I,O> extends WrappedFunction<I,O,reactor.core.publisher.Flux<I>,reactor.core.publisher.Mono<O>,Function<reactor.core.publisher.Flux<I>,reactor.core.publisher.Mono<O>>>
Function<Flux<?>, Mono<?>>
.
While it may look similar to FluxedConsumer
the fundamental difference is that
this class represents a function that returns Mono
of type <O>
, while
FluxedConsumer
is a consumer that has been decorated as
Function<Flux<?>, Mono<Void>>
.Constructor and Description |
---|
FluxToMonoFunction(Function<reactor.core.publisher.Flux<I>,reactor.core.publisher.Mono<O>> target) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<O> |
apply(reactor.core.publisher.Flux<I> input) |
getTarget
Copyright © 2019 Pivotal Software, Inc.. All rights reserved.