From 18ab300781f8544bde0af3bdf67aa4d821f7b26f Mon Sep 17 00:00:00 2001 From: zhangyue000 <543108700@qq.com> Date: Sun, 13 Apr 2025 18:31:01 +0800 Subject: [PATCH] =?UTF-8?q?[fit]=20=E4=BF=AE=E5=A4=8D=E5=B9=BF=E6=92=AD?= =?UTF-8?q?=E6=A8=A1=E5=BC=8F=E4=B8=8B=E5=A6=82=E6=9E=9Cgenericable?= =?UTF-8?q?=E6=97=A0=E8=BF=94=E5=9B=9E=E5=80=BC=E6=97=B6=E7=9A=84=E6=8A=A5?= =?UTF-8?q?=E9=94=99=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../fitframework/broker/support/MulticastFitableExecutor.java | 2 +- .../broker/support/MulticastGenericableExecutor.java | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/framework/fit/java/fit-broker/src/main/java/modelengine/fitframework/broker/support/MulticastFitableExecutor.java b/framework/fit/java/fit-broker/src/main/java/modelengine/fitframework/broker/support/MulticastFitableExecutor.java index aa515062..ade6de21 100644 --- a/framework/fit/java/fit-broker/src/main/java/modelengine/fitframework/broker/support/MulticastFitableExecutor.java +++ b/framework/fit/java/fit-broker/src/main/java/modelengine/fitframework/broker/support/MulticastFitableExecutor.java @@ -53,7 +53,7 @@ public Object execute(Fitable fitable, List 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) { diff --git a/framework/fit/java/fit-broker/src/main/java/modelengine/fitframework/broker/support/MulticastGenericableExecutor.java b/framework/fit/java/fit-broker/src/main/java/modelengine/fitframework/broker/support/MulticastGenericableExecutor.java index 974dd2e3..50f068a9 100644 --- a/framework/fit/java/fit-broker/src/main/java/modelengine/fitframework/broker/support/MulticastGenericableExecutor.java +++ b/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 fitables, InvocationContext context, Object[ fitable.toUniqueId()); return null; } - }).reduce(context.accumulator()).orElse(null); + }).filter(Objects::nonNull).reduce(context.accumulator()).orElse(null); } }