public class LocalFunctionGateway extends Object implements FunctionGateway
| Constructor and Description |
|---|
LocalFunctionGateway(FunctionCatalog catalog,
org.springframework.scheduling.TaskScheduler scheduler) |
| Modifier and Type | Method and Description |
|---|---|
<T,R> R |
invoke(String functionName,
T request) |
<T,R> void |
schedule(String functionName,
org.springframework.scheduling.Trigger trigger,
Supplier<T> supplier,
Consumer<R> consumer) |
<T,R> void |
subscribe(org.reactivestreams.Publisher<T> publisher,
String functionName,
Consumer<R> consumer) |
public LocalFunctionGateway(FunctionCatalog catalog, org.springframework.scheduling.TaskScheduler scheduler)
public <T,R> R invoke(String functionName, T request)
invoke in interface FunctionGatewaypublic <T,R> void schedule(String functionName, org.springframework.scheduling.Trigger trigger, Supplier<T> supplier, Consumer<R> consumer)
schedule in interface FunctionGatewaypublic <T,R> void subscribe(org.reactivestreams.Publisher<T> publisher,
String functionName,
Consumer<R> consumer)
subscribe in interface FunctionGatewayCopyright © 2017 Pivotal Software, Inc.. All rights reserved.