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

For #I8MW6Q, 完善测试用例

Browse Source
This commit is contained in:
DaleLee
2024-02-02 16:15:17 +08:00
parent d555a2ab43
commit d5e3a22014
9 changed files with 23 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -306,19 +306,7 @@ public class FlowBus {
// 移除节点
public static boolean removeNode(String nodeId) {
Node node = getNode(nodeId);
if (node == null) {
// 节点不存在
return false;
}
nodeMap.remove(nodeId);
// 如果是脚本节点，移除脚本
if (node.getType().isScript()) {
ScriptExecutorFactory.loadInstance()
.getScriptExecutor(node.getLanguage())
.unLoad(nodeId);
}
return true;
return nodeMap.remove(nodeId) != null;
}
// 判断是否是降级组件，如果是则添加到 fallbackNodeMap
@@ -346,6 +334,20 @@ public class FlowBus {
.load(nodeId, script);
}
// 卸载脚本节点
public static boolean unloadScriptNode(String nodeId) {
Node node = getNode(nodeId);
if (node == null || !node.getType().isScript()) {
return false;
}
// 卸载脚本
ScriptExecutorFactory.loadInstance()
.getScriptExecutor(node.getLanguage())
.unLoad(nodeId);
// 移除脚本
return removeNode(nodeId);
}
public static void clearStat(){
initStat.set(false);
}