[fit] 修复广播模式下如果genericable无返回值时的报错问题 (#42)

Author: zhangyue000

framework/fit/java/fit-broker/src/main/java/modelengine/fitframework/broker/support/MulticastFitableExecutor.java

@@ -53,7 +53,7 @@ public Object execute(Fitable fitable, List<Target> targets, InvocationContext c
                         fitable.toUniqueId());
                 return null;
             }
-        }).reduce(context.accumulator()).orElse(null);
+        }).filter(Objects::nonNull).reduce(context.accumulator()).orElse(null);
     }
 
     private Object execute(Fitable fitable, Target target, InvocationContext context, Object[] args) {

framework/fit/java/fit-broker/src/main/java/modelengine/fitframework/broker/support/MulticastGenericableExecutor.java

@@ -13,6 +13,7 @@
 
 import java.util.Collections;
 import java.util.List;
+import java.util.Objects;
 
 /**
  * 表示 {@link GenericableExecutor} 的多播调用实现。
@@ -39,6 +40,6 @@ public Object execute(List<Fitable> fitables, InvocationContext context, Object[
                         fitable.toUniqueId());
                 return null;
             }
-        }).reduce(context.accumulator()).orElse(null);
+        }).filter(Objects::nonNull).reduce(context.accumulator()).orElse(null);
     }
 }