T
- input type of target functionR
- output type of target functionpublic class FluxFunction<T,R> extends Object implements Function<reactor.core.publisher.Flux<T>,reactor.core.publisher.Flux<R>>, FluxWrapper<Function<T,R>>
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<T,R> function) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<R> |
apply(reactor.core.publisher.Flux<T> input) |
Function<T,R> |
getTarget() |
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.