android - Observable.zip() 被异步执行

Question

我正在编写一个 Android 应用程序，使用 RxJava、Retrofit 和 Clean Architecture。问题是我有一个 Interactor/UseCase 需要返回最喜欢的球队和最喜欢的球员的集合。最喜欢的球队的集合是一个端点与另一个端点混合的结果。最喜欢的球员也是如此。在 Interactor/UseCase 实现中，我正在做这样的事情:

getTeams = Observable.merge(mNetworkRetrofitService.getAllTeams(), mNetworkRetrofitService.getAllFavoriteTeams());
getPlayers = Observable.merge(mNetworkRetrofitService.getAllPlayers(), mNetworkRetrofitService.getAllFavoritePlayers());

然后我将这两个响应压缩在一起，将它们返回到一个包装器对象中:

Observable.zip(getTeams, getPlayers, new Func2<List<Team>, List<Player>, Pair<List<Team>, List<Player>>>() {
    @Override
    public Pair<List<Team>, List<Player>> call(List<Team> teamList, List<Player> players) {
        return new Pair<>(teamList, players);
    }
}).subscribe(new DefaultSubscriber<Pair<List<Team>, List<Player>>>() {

    @Override
    public void onNext(Pair<List<Team>, List<Player>> pair) {
        callback.showResultOnUI(pair);
    }

});

我知道 .zip() 方法应该等到两个 rx.Observables 结束发射项目，但在这种情况下，混合方法被执行了不止一次。

我的问题是；有没有办法避免 zip 的合并方法被多次执行？

请记住以下几点:

• 我简化了示例。实际上，我还将缓存 rx.Observable 与 Retrofit 的 rx.Observables 合并。

• 端点不能改变。包装器对象无法更改。响应必须在单个对象包装器中返回到 te UI。我们不能在两种不同的回调方法中发送最喜欢的球队和最喜欢的球员。

Answer 1

所以，你的 zip方法被多次调用，因为你对 List<T> 采取行动秒。这意味着这个 Observable:

getTeams = Observable.merge(
      mNetworkRetrofitService.getAllTeams(), 
      mNetworkRetrofitService.getAllFavoriteTeams());

将有 2 个项目，每个项目都是一个列表 - 它不会将它们全部合并在一起。你想要的是将两个列表合并为一个:

getTeams = Observable.merge(
      mNetworkRetrofitService.getAllTeams(), 
      mNetworkRetrofitService.getAllFavoriteTeams())
.flatMap(Observable::fromIterable()
.toList();

如果你为你的 zip 都这样做参数，那么你只会得到一个发射。