I
- input type of target functionO
- output type of target functionpublic class FluxFunction<I,O> extends WrappedFunction<I,O,reactor.core.publisher.Flux<I>,reactor.core.publisher.Flux<O>,Function<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.Constructor and Description |
---|
FluxFunction(Function<I,O> target) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<O> |
apply(reactor.core.publisher.Flux<I> input) |
getTarget
Copyright © 2022 Pivotal Software, Inc.. All rights reserved.