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

Add null check for function registration in composite

Browse Source
This commit is contained in:
Dave Syer
2019-02-25 14:34:10 +00:00
parent 32987230c1
commit ab9c82753f
1 changed files with 14 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/AbstractComposableFunctionRegistry.java
View File

@@ -315,18 +315,20 @@ public abstract class AbstractComposableFunctionRegistry implements FunctionRegi
FunctionRegistration<?> composedRegistration = composableFunctions FunctionRegistration<?> composedRegistration = composableFunctions
.stream().reduce((a, z) -> composeFunctions(a, z)) .stream().reduce((a, z) -> composeFunctions(a, z))
.orElseGet(() -> null); .orElseGet(() -> null);
composedFunction = composedRegistration.getTarget(); if (composedRegistration != null) {
if (composedFunction != null && !this.types.containsKey(name)) { composedFunction = composedRegistration.getTarget();
this.addType(name, composedRegistration.getType()); if (composedFunction != null && !this.types.containsKey(name)) {
this.addName(composedFunction, name); this.addType(name, composedRegistration.getType());
if (composedFunction instanceof Function) { this.addName(composedFunction, name);
this.addFunction(name, (Function<?, ?>) composedFunction); if (composedFunction instanceof Function) {
} this.addFunction(name, (Function<?, ?>) composedFunction);
else if (composedFunction instanceof Consumer) { }
this.addConsumer(name, (Consumer<?>) composedFunction); else if (composedFunction instanceof Consumer) {
} this.addConsumer(name, (Consumer<?>) composedFunction);
else if (composedFunction instanceof Supplier) { }
this.addSupplier(name, (Supplier<?>) composedFunction); else if (composedFunction instanceof Supplier) {
this.addSupplier(name, (Supplier<?>) composedFunction);
}
} }
} }
} }