本文介绍如何利用 quarkus mutiny 的 `multi` 与 `transformtouniandconcatenate`，对列表中的元素**逐个、顺序、异步**调用返回 `uni
在响应式编程中，“顺序执行多个异步操作”是一个常见但易错的需求——尤其当每个操作返回 Uni（单值异步流）且需严格串行（前一个完成后再触发下一个）、同时要求失败不中断整体流程时，直接使用 flatMap 或 concatenate 易导致错误传播或并发失控。
Mutiny 提供了优雅的解决方案：借助 Multi.createFrom().iterable() 将元素列表转为多值流，再通过 onItem().transformToUniAndConcatenate(...) 实现串行化 Uni 转换——该操作符会等待前一个 Uni 完成（无论成功或失败），再启动下一个，天然满足“顺序 + 容错”双重要求。
✅ 正确实现如下：
import io.smallrye.mutiny.Multi; import io.smallrye.mutiny.Uni; // 假设 elements 非 null MultisequentialResults = Multi.createFrom() .iterable(elements) .onItem() .transformToUniAndConcatenate(element -> asyncMethod(element) .onFailure() // 捕获任意异常（包括 RuntimeException） .recoverWithItem("fallback_" + element.getId()) // 自定义降级值（类型需匹配 String） // 或 .continueWith(() -> Uni.createFrom().item("default")) );
⚠️ 关键注意事项：
- transformToUniAndConcatenate 是唯一保证严格串行的转换算子；transformToUniAndFlatMap 会并发执行，transformToUniAndMerge 则无序合并。
- .onFailure().recoverWithItem(...) 必须返回与 Uni
类型一致的值（如 String），否则编译失败；若需更复杂错误处理（如日志+默认值），可用 .onFailure().invoke(log::error).recoverWithItem(...)。 - 若需收集全部结果，可追加 .collect().asList() 得到 Uni
- >；若需实时消费，用 .subscribe().with(System.out::println)。
? 总结：当面对“列表 → 逐个异步调用 → 顺序 + 失败继续”场景时，Multi.iterable(...).transformToUniAndConcatenate(...) 是 Mutiny 中最简洁、语义最清晰的标准模式——它将控制流逻辑完全声明化，无需手写递归或状态管理，兼顾可读性与健壮性。
