SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-568 Add support for casting resulting function as Runnable

Browse Source 
Resolves #568
This commit is contained in:
Oleg Zhurakousky
2020-09-21 17:22:38 +02:00
parent 6863931f30
commit 4d49b4d6ec
2 changed files with 14 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java
View File

@@ -415,7 +415,8 @@ public class SimpleFunctionRegistry implements FunctionRegistry, FunctionInspect
*
* @author Oleg Zhurakousky
*/
public class FunctionInvocationWrapper implements Function<Object, Object>, Consumer<Object>, Supplier<Object> {
public class FunctionInvocationWrapper implements Function<Object, Object>, Consumer<Object>,
Supplier<Object>, Runnable {
private final Object target;
@@ -519,6 +520,11 @@ public class SimpleFunctionRegistry implements FunctionRegistry, FunctionInspect
return this.doApply(input, false, enricher);
}
@Override
public void run() {
this.apply(null);
}
public Type getFunctionType() {
return this.functionType;
}

7
spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/catalog/BeanFactoryAwareFunctionRegistryTests.java
View File

@@ -484,6 +484,13 @@ public class BeanFactoryAwareFunctionRegistryTests {
assertThat(f.apply("Bubbles")).isEqualTo("BUBBLES");
}
@Test
public void testSupplierConsumerAsRunnable() {
FunctionCatalog catalog = this.configureCatalog(SampleFunctionConfiguration.class);
Runnable f = catalog.lookup("numberword|imperativeConsumer");
f.run();
}
@EnableAutoConfiguration
public static class PojoToMessageFunctionCompositionConfiguration {