不能使用 RX Android Observable.zip 运算符

Question

我正在使用 rx-android zip 运算符合并两个改造调用。

之前的代码是这样的：

  affinityService.rewardsStatusChanges()
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .compose(this.<RewardsStatus>bindToLifecycle())
            .subscribe(new Action1<RewardsStatus>() {
                @Override
                public void call(RewardsStatus rewardsStatus) {
                    onRewardStatus(rewardsStatus);
                }
            });

    affinityService.affinityStatusChanges()
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .compose(this.<AffinityStatus>bindToLifecycle())
            .subscribe(new Action1<AffinityStatus>() {
                @Override
                public void call(AffinityStatus affinityStatus) {
                    onAffinityStatus(affinityStatus);
                }
            });

rewardsStatusChanges() 和 affinityStatusChanges() 是两个改造调用。

现在我需要合并它们。

我尝试过的：

affinityService.rewardsStatusChanges()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .compose(this.<RewardsStatus>bindToLifecycle())
                .flatMap(new Func1<RewardsStatus, Observable<RewardsStatus>>() {
                    @Override
                    public Observable<RewardsStatus> call(RewardsStatus rewardsStatus) {
                        return Observable.just(rewardsStatus);
                    }
                })
                .flatMap(new Func1<RewardsStatus, Observable<RewardsStatus>>() {
                    @Override
                    public Observable<RewardsStatus> call(RewardsStatus rewardsStatus) {
                        return Observable.zip(Observable.just(rewardsStatus),
                        affinityService.affinityStatusChanges(),new Func2<RewardsStatus, AffinityStatus, RewardsStatus>() {
                                    @Override
                                    public RewardsStatus call(RewardsStatus rewardsStatus, AffinityStatus affinityStatus) {
                                        onAffinityAndRewardsMerged(rewardsStatus,affinityStatus);
                                        return null;
                                    }

                        });
                    }
                });

但不幸的是，上面的代码库无法正常工作。知道如何做到这一点。

我正在使用：

RX_ANDROID_VERSION=1.0.1
RX_JAVA_VERSION=1.0.14

Answer 1

随心所欲地发布，但是在匿名函数中使用 return null 你将在消费者中得到 null，所以我认为 returning 像 Pair<RewardsStatus,AffinityStatus> 会更好，并在消费者中进行结果处理。

 Observable.zip(affinityService.rewardsStatusChanges(), affinityService.affinityStatusChanges(),
            object : Func2<RewardsStatus, AffinityStatus, RewardsStatus>() {
                fun call(rewardsStatus: RewardsStatus, affinityStatus: AffinityStatus): RewardsStatus? {
                    onAffinityAndRewardsMerged(rewardsStatus, affinityStatus)
                    return null
                }
            })

不能使用 RX Android Observable.zip 运算符

Cannot use RX Android Observable.zip operator

android

rx-android