java - RxJava 条件中断链

Question

我正在创建一个可观察的序列，我基本上是在寻找一种在不满足条件时打破链条的好方法。理想情况下，我们可以通过这种情况下的错误。这基本上是为了删除平面图运算符中的 if/else 语句。这就是我现在拥有的东西

flatMap(new Func1<User, Observable<Response>>() {
                    @Override
                    public Observable<Response> call(Result result) {
                        if(isValid(result))) {
                            return api.getObservableResponse(); //some retrofit observable
                        } else {
                            observer.onError();
                            return null; //??? I guess this would force an error
                        }
                    }
                })

我见过诸如 filter() 和所有其他条件运算符之类的运算符，但我不确定它们是否满足我的要求。有一个更好的方法吗？还是我看起来不错？谢谢!

Answer 1

如何使用 takeWhile - docs ？

Observable<T> whatever = ...

Observable<T> untilConditionMet = whatever
   .takeWhile(this::isValid) // modify according wherever isValid comes from
   .flatMap(r -> api.getObservableResponse()); // only doing this until isValid