java - 如何在 RX java 链中使用 "if-else"？

Question

我是 RXJava/RXAndroid 的新手。我想实现这种情况:根据 RXJava 中的某些条件选择不同的方式。 例如，首先，我从网络中获取用户信息，如果这是 VIP 用户，我将继续从网络中获取更多信息，或者只在主线程中显示一些信息(打破链条。)这里的流程图:/image/0hztR.png

我对此做了一些搜索，只发现“switchIfEmpty”可能有帮助。 我写了下面的代码:

getUserFromNetwork("userId")
                .flatMap(new Function<User, ObservableSource<User>>() {
                    @Override
                    public ObservableSource<User> apply(User user) throws Exception {
                        if(!user.isVip){
                            //show user info on MainThread!
                            return Observable.empty();
                        }else{
                            return getVipUserFromNetwork("userId");
                        }
                    }
                }).switchIfEmpty(new ObservableSource<User>() {
                    @Override
                    public void subscribe(Observer<? super User> observer) {
                        //show user info in main thread
                        //just break the chain for normal user
                        observer.onComplete();
                    }
                }).doOnNext(new Consumer<User>() {
                    @Override
                    public void accept(User user) throws Exception {
                        //show vip user info in main thread
                    }
                }).subscribe();

有没有更简单的方法来实现这个？

谢谢!

Answer 1

flatMap() 是一个不错的选择，您可以用它拆分流，但最后流合并在一起(每个拆分的可观察流的所有排放都流向主流)。 在您的代码中，switchIfEmpty() 是多余的，因为这正是 Observable.empty() 所做的(立即调用 onCompleted())，如果您希望显示在主线程上发生，您当然还需要观察者开启，但无论如何，我认为在流中间处理它不是一个好习惯。

我认为在您的情况下，您可以在单个处理程序中处理(响应)用户发射，因为它非常相似，只需检查它是否是 VIP 并相应地显示它。 所以它应该看起来像这样:

getUserFromNetwork("userId")
            .flatMap(new Function<User, ObservableSource<User>>() {
                @Override
                public ObservableSource<User> apply(User user) throws Exception {
                    if (!user.isVip) {
                        return Observable.just(user);
                    } else {
                        return getVipUserFromNetwork("userId");
                    }
                }
            })
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(user -> {
                if (user.isVip){
                    //display vip user
                }else{
                    //display regular user
                }
            });

在这种方法中，您有一个单一的流，在流的中间没有“副作用”。

如果你处理的是完全不同的(这不是这种情况)，那么你可以将流拆分为 2 个独立的流并对每个流做出不同的 react ，这可以通过多播你的 getUserFromNetwork() 来完成 Observable，并从这个 Observable 创建 2 个不同的 Observable，一个将继续，例如 getVipUserFromNetwork()，一个不'，并且每个都可以有不同的订阅者逻辑。 (你可以阅读 here 我关于多播的回答)