org.springframework.cloud.function.core

Class FluxFunction<I,O>

java.lang.Object

org.springframework.cloud.function.core.WrappedFunction<I,O,reactor.core.publisher.Flux<I>,reactor.core.publisher.Flux<O>,Function<I,O>>

org.springframework.cloud.function.core.FluxFunction<I,O>

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<I,O>>

public 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.

Author:

Mark Fisher, Oleg Zhurakousky

Constructor Summary

Constructors

Constructor and Description
FluxFunction(Function<I,O> target)

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux<O>	apply(reactor.core.publisher.Flux<I> input)

Methods inherited from class org.springframework.cloud.function.core.WrappedFunction

getTarget

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Constructor Detail

FluxFunction

public FluxFunction(Function<I,O> target)

Method Detail

apply

public reactor.core.publisher.Flux<O> apply(reactor.core.publisher.Flux<I> input)