响应式编程中如何将flatMap内的if-else合并为单次返回？

云原生阿岚

2026-5-15

优雅重构你的RxJava代码

嘿，这个需求太常见了！咱们完全可以用filter + defaultIfEmpty的组合来干掉那个显式的if/else分支，让代码更符合RxJava的链式风格。我给你拆解下思路，直接上重构后的代码：

重构后的完整代码

.flatMap(sth -> {
    Obj obj = sth.getSomeLast();
    return Single.just(obj)
        // 只留下需要加载info的场景（对应原逻辑的if分支）
        .filter(o -> o.someField == null)
        // 加载info并映射成目标Entry
        .flatMap(o -> dao.loadInfo(o.id).map(info -> new Entry(1, 2, info)))
        // 兜底处理不需要加载的场景（对应原逻辑的else分支）
        .defaultIfEmpty(new Entry(1, 2, null));
})
.doOnNext(entry -> writer(entry));

逻辑拆解（对应原代码的分支）

原if分支（需要加载info）：通过filter(o -> o.someField == null)筛选出需要加载的obj，接着用flatMap调用dao.loadInfo并映射成带info的Entry。
原else分支（直接返回默认Entry）：如果filter后流为空（也就是obj.someField不为null），defaultIfEmpty会自动返回我们预设的Entry(1, 2, null)，完美替代else的返回逻辑。