com.fnproject.springframework.function.functions

Class SpringCloudMethod

java.lang.Object

com.fnproject.springframework.function.functions.SpringCloudMethod

All Implemented Interfaces:

MethodWrapper

Direct Known Subclasses:

SpringCloudConsumer, SpringCloudFunction, SpringCloudSupplier

public abstract class SpringCloudMethod
extends Object
implements MethodWrapper

Superclass for classes which represent java.util.function.* objects as Spring Cloud Functions

Method Summary

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

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

Method Detail

getTargetClass

public Class<?> getTargetClass()

Specified by:

getTargetClass in interface MethodWrapper

getTargetMethod

public Method getTargetMethod()

Specified by:

getTargetMethod in interface MethodWrapper

getMethodName

protected abstract String getMethodName()

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

Returns:

name of the method used to invoke the function object

getFunction

protected abstract Object getFunction()

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

Returns:

target function object

getParamType

public TypeWrapper getParamType(int index)

Specified by:

getParamType in interface MethodWrapper

getReturnType

public TypeWrapper getReturnType()

Specified by:

getReturnType in interface MethodWrapper

invoke

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

Invoke the target function object

Parameters:

arg - fuction invoke arguments

Returns:

Flux type object