Reactor Mono.zipWhen 为何不发射元素？正确替代方案解析

当使用 `zipwhen` 操作符时，若其生成的右侧 `mono` 为空（如 `mono.empty()` 或 `mono`），整个流将静默完成而不发射任何元素——这是因为 `zipwhen` 要求两侧均有值才能组合成 `tuple2`，空流导致“无物可合”。

zipWhen 的设计语义是等待左侧 Mono 发射一个值后，用该值动态生成一个右侧 Mono，再将两者“配对”组合为 Tuple2。关键前提是：右侧 Mono 必须成功发射一个非空值（即 onNext），否则无法完成 zip 动作。

在你的代码中：

Mono<Void> processUser(User user) {
    return Mono.empty(); // ❌ 不发射任何元素，仅 onComplete
}

Mono.empty() 立即完成（onComplete），不触发 onNext，因此 zipWhen 无法构造 Tuple2（即使 Void 是合法类型，也需实际发射），最终整个链路以“完成但无数据”结束——这正是你观察到 doSomething2 不发射 User 的根本原因。

⚠️ 注意：Mono 本身并不等价于“空”，它表示“无值语义的操作完成”，但 zipWhen 仍要求其显式调用 onNext(null) 才能参与 zip（尽管不推荐）。而 Mono.empty() 连 onNext 都不发出，直接 onComplete，故 zip 失败。

Zyro AI Image Upscaler

Zyro出品的AI图片放大工具

下载

✅ 正确做法：根据实际意图选择更合适的操作符：

• 若仅需“执行副作用后透传原值”（如日志、缓存、异步通知等），应使用 flatMap + thenReturn：

  Mono<User> doSomething2(String username) {
      return userService.getUser(username)
              .flatMap(user -> 
                  processUser(user) // 返回 Mono<Void> 或 Mono.empty()
                      .thenReturn(user) // 显式将原 user 作为下一阶段输出
              )
              .doOnError(error -> LOG.error("Processing failed", error));
  }

• 若确实需要合并两个有值的结果（如 User + Profile），则 processUser 应返回一个非空的、携带有效数据的 Mono：

  Mono<Profile> processUser(User user) {
      return profileService.getProfile(user.getId()); // ✅ 发射 Profile 实例
  }
  
  // 此时 zipWhen 可正常工作：
  .zipWhen(this::processUser)
  .map(tuple -> new EnrichedUser(tuple.getT1(), tuple.getT2()))

? 总结：

• zipWhen ≠ “执行后继续”，而是“配对合并”，强依赖右侧 Mono 的 onNext 事件；
• Mono.empty() / Mono（未调用 onNext(null)）会导致 zip 流静默终止；
• 日常开发中，对“处理+透传”场景，优先选用 flatMap(...).thenReturn(original)，语义清晰、行为确定、调试友好。