com.fnproject.springframework.function.functions

Class SpringCloudConsumer

java.lang.Object

com.fnproject.springframework.function.functions.SpringCloudMethod

com.fnproject.springframework.function.functions.SpringCloudConsumer

All Implemented Interfaces:

MethodWrapper

public class SpringCloudConsumer
extends SpringCloudMethod

SpringCloudMethod representing a Consumer

Constructor Summary

Constructors

Constructor and Description
SpringCloudConsumer(Consumer<reactor.core.publisher.Flux<?>> consumer, org.springframework.cloud.function.context.catalog.FunctionInspector inspector)

Method Summary

Modifier and Type	Method and Description
protected Object	getFunction() Returns the target function object as an Object.
protected String	getMethodName() Returns the name of the method used to invoke the function object.
TypeWrapper	getReturnType()
reactor.core.publisher.Flux<?>	invoke(reactor.core.publisher.Flux<?> arg) Invoke the target function object

Methods inherited from class com.fnproject.springframework.function.functions.SpringCloudMethod

getParamType, getTargetClass, getTargetMethod

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.fnproject.fn.api.MethodWrapper

getLongName, getParameterCount

Constructor Detail

SpringCloudConsumer

public SpringCloudConsumer(Consumer<reactor.core.publisher.Flux<?>> consumer,
                           org.springframework.cloud.function.context.catalog.FunctionInspector inspector)

Method Detail

getMethodName

protected String getMethodName()

Description copied from class: SpringCloudMethod

Returns the name of the method used to invoke the function object. e.g. apply for Function, accept for Consumer, get for Supplier

Specified by:

getMethodName in class SpringCloudMethod

Returns:

name of the method used to invoke the function object

getFunction

protected Object getFunction()

Description copied from class: SpringCloudMethod

Returns the target function object as an Object. (used for type inspection purposes)

Specified by:

getFunction in class SpringCloudMethod

Returns:

target function object

getReturnType

public TypeWrapper getReturnType()

Specified by:

getReturnType in interface MethodWrapper

Overrides:

getReturnType in class SpringCloudMethod

invoke

public reactor.core.publisher.Flux<?> invoke(reactor.core.publisher.Flux<?> arg)

Description copied from class: SpringCloudMethod

Invoke the target function object

Specified by:

invoke in class SpringCloudMethod

Parameters:

arg - fuction invoke arguments

Returns:

Flux type object