public/liteFlow
1
0
Fork 0
mirror of https://gitee.com/dromara/liteFlow.git synced 2026-05-14 20:22:07 +08:00
Code Issues Packages Projects Releases Wiki Activity

优化FlowBus代码的格式

Browse Source
This commit is contained in:
everywhere.z
2022-09-20 00:10:12 +08:00
parent b266318c59
commit 3d37048d40
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
liteflow-core/src/main/java/com/yomahub/liteflow/flow/FlowBus.java
View File

@@ -192,12 +192,17 @@ public class FlowBus {
}
//进行初始化
cmpInstances = cmpInstances.stream()
.map(
cmpInstance -> ComponentInitializer.loadInstance().initComponent(cmpInstance, type, name, cmpInstance.getNodeId() == null ? nodeId : cmpInstance.getNodeId())).collect(Collectors.toList());
.map(cmpInstance -> ComponentInitializer.loadInstance().initComponent(
cmpInstance,
type,
name,
cmpInstance.getNodeId() == null ? nodeId : cmpInstance.getNodeId())
).collect(Collectors.toList());
//初始化Node
List<Node> nodes = cmpInstances.stream().map(Node::new).collect(Collectors.toList());
//如果是脚本节点，则还要加载script脚本
for (int i = 0; i < nodes.size(); i++) {
Node node = nodes.get(i);
NodeComponent cmpInstance = cmpInstances.get(i);
@@ -212,7 +217,6 @@ public class FlowBus {
}
}
String activeNodeId = StrUtil.isEmpty(cmpInstance.getNodeId()) ? nodeId : cmpInstance.getNodeId();
//如果是脚本节点(普通脚本节点/条件脚本节点)，则还要加载script脚本
nodeMap.put(activeNodeId, node);
}
} catch (Exception e) {