java - 结合最新的和冷的观察结果

Question

给定以下代码:

        Observable<String> obs1 = Observable.just("1", "2", "3");
        Observable<String> obs2 = Observable.just("a", "b");
        Observable.combineLatest(obs1,
                                 obs2,
                                 (s1, s2) -> s1 + ":" + s2
        ).subscribe(System.out::println);

我希望它打印如下内容:

1:a
2:a
3:a
3:b

但是它打印

3:a
3:b

为什么我的第一个 Observable 只发出最后一项？在 combineLatest 之前没有活跃的订阅，所以它应该是冷的。我怎样才能确保来自两个 Observable 的所有项目都组合在一起？

Answer 1

发生这种情况是因为您有同步源。当 combineLatest 订阅其来源时，默认情况下它会从中预取 128 个元素。这意味着您的第一个源将同步运行直至完成，而第二个订阅甚至在该完成之前不会发生。由于第一个源是单独的，因此除了最后一个元素之外的所有元素都会被丢弃。一旦订阅了第二个源，它将从第一个源中找到最后一个源并将自己与它结合。

你想达到什么目的？如果要成对组合，请使用 zip。如果您想要 first 和 second 的所有组合，请使用 flatMap:

obs1.flatMap(v -> obs2.map(w -> v + ":" + w)).subscribe(...)