如何利用yield星号的高阶传播特性在低代码引擎中实现可视化业务算子的链式流级联

yield*在低代码引擎中实现可视化算子链式流级联，本质是将数据流的暂停、恢复、委托与上下文传递能力映射到节点执行生命周期，使整条链如呼吸顺畅的河流而非孤立水闸。

直接用 yield*（注意：JavaScript 中为 yield*，Python 中对应的是 yield from）在低代码引擎中实现可视化业务算子的链式流级联，核心不是“加个语法糖”，而是把数据流的暂停、恢复、委托与上下文传递能力，映射到可视化节点的执行生命周期里。它解决的是：当用户拖拽出“查询订单 → 过滤异常 → 计算折扣 → 推送通知”这样一串节点时，如何让整条链像一条呼吸顺畅的河流，而非多个孤立水闸。

业务算子本质是可中断的数据处理函数

在运行时引擎中，每个可视化算子（如“HTTP 请求”“条件分支”“JSON 转换”）不应被编译成同步阻塞调用，而应建模为一个返回 AsyncGenerator（JS）或 async def + yield from（Python）的函数。例如：

• “分页拉取用户列表”算子 → 每次 yield 一页数据，不一次性加载全部；
• “实时风控校验”算子 → 对每条流入事件 yield 校验结果，支持背压；
• “聚合统计”算子 → 内部维护状态，yield 中间聚合值，最后 return 终态。

这样，算子本身天然具备“流感知”能力，无需额外封装适配层。

yield* 实现跨节点控制权无缝移交

当流程图连线从 A 算子指向 B 算子时，引擎不生成 await A(); await B(); 这类线性调用，而是生成类似以下结构的协程链：

async function* executeChain() {  yield* await nodeA(); // 委托执行A，A内部可多次yield  yield* await nodeB(); // A结束后，B立即接管，且可接收A的最终状态（如return值）}

关键点在于：yield* 不仅转发产出值，还自动透传 throw() 和 return()——这意味着：

• 若 B 算子中途抛错，错误可原路回溯至 A 的上下文，便于可视化调试器定位断点；
• 若 A 算子执行完毕 return { cursor: "abc123" }，B 算子可通过 yield* 的委托机制直接读取该返回值，用于续传分页或幂等标识；
• 整个链保持单个 generator 实例，内存栈深度恒定，避免嵌套 for await...of 带来的隐式递归膨胀。

可视化设计器需暴露“流契约”配置项

普通拖拽无法发挥 yield* 优势，必须在设计态就引导用户声明流行为。建议在节点属性面板增加三项：

• 输入模式：单条事件 / 批量数组 / 持续流（决定算子是否启用 yield 多次）；
• 输出契约：是否携带元数据（如 { data, meta: { timestamp, seq } }），供下游 yield* 解构；
• 中断策略：失败时继续下一条（soft fail）、终止整链（hard fail）、还是交由上游重试（retryable）——这直接影响 yield* 如何处理 throw。

例如，“数据库写入”节点若设为 retryable，其底层实现会包装 yield from retry_wrapper(db_insert())，而下游节点通过 yield* 自动继承重试上下文，无需重复配置。

运行时引擎需注入轻量调度上下文

yield* 是被动委托，引擎需主动管理流节奏。推荐在执行链顶层注入一个 ContextToken，携带：

• 当前 traceId 与 spanId（用于全链路日志对齐）；
• 最大并发度（控制 yield* 并行展开深度）；
• 超时预算（每个 yield* 委托前检查剩余时间）。

这样，当用户在画布上连接 12 个算子时，引擎不会生成 12 层嵌套 yield*，而是动态拆分为若干子链（如按事务边界），每条子链内用 yield* 保序，子链间用 Promise.allSettled 协调——既保持语义清晰，又规避栈溢出风险。