在响应式流中，若需在 flux 发出首个元素时（且仅当至少有一个元素存在）执行一次阻塞式初始化方法（如 setuprepo），可借助 switchonfirst 操作符实现条件触发，避免空流误调或重复执行。
在响应式流中，若需在 flux 发出首个元素时（且仅当至少有一个元素存在）执行一次阻塞式初始化方法（如 setuprepo），可借助 switchonfirst 操作符实现条件触发，避免空流误调或重复执行。
switchOnFirst 是 Project Reactor 提供的高级操作符，专用于对 Flux 的“首个信号”（可能是 onNext、onComplete 或 onError）进行探测和干预。它接收一个 BiFunction<Signal<T>, Flux<T>, Publisher<T>>，其中 Signal<T> 封装了第一个事件的类型与值信息，而 flux 是原始流（不含首个元素）——这意味着你可在不消费数据的前提下安全判断流是否非空，并执行副作用。
以下为推荐实现方案：
externalApi
.getAllItems()
.switchOnFirst((signal, flux) -> {
if (signal.hasValue()) {
setupRepo(); // ✅ 仅当至少一个 Item 即将被发出时才调用
}
return flux; // 继续下游流，保持原始元素顺序与完整性
})
.flatMap(item ->
itemsRepo.saveItem(item)
.doOnNext(e -> logSaveResult(item, e))
.doOnError(th -> logSaveError(item, th))
)
.subscribe();⚠️ 注意事项：
- setupRepo() 是阻塞式、无返回值的普通方法，因此必须在 switchOnFirst 的 lambda 内直接调用，不可包裹为 Mono.fromRunnable() 等响应式类型，否则会破坏执行时机与线程上下文；
- signal.hasValue() 判断的是首个信号是否为 onNext（即流非空），若流为空（立即 onComplete），则 signal.isComplete() 为 true，setupRepo() 不会被调用；
- switchOnFirst 不会丢弃首个元素——flux 已包含全部原始元素（包括第一个），因此无需手动 concatWith(Mono.just(signal.get()))；
- 该操作符是惰性执行的，仅在订阅后、首个信号到达时触发，符合响应式生命周期语义。
✅ 总结：switchOnFirst 是解决“流级前置条件执行”问题的标准、简洁且线程安全的方式，优于 materialize/dematerialize、hasElements().filter(true).flatMap(...) 等冗余方案，也规避了 blockFirst() 等破坏响应式契约的反模式。
