android-RxJava：如何从flatMap运算符中的错误中恢复

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了android-RxJava：如何从flatMap运算符中的错误中恢复，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1822字，纯文字阅读大概需要3分钟。

内容图文

我有一个EditText,用户在其中输入搜索查询,当用户键入内容时,我想在服务器上执行即时搜索.

我尝试使用RxJava做到这一点,如下所示：

RxTextView.textChanges(editQuery) // I'm using RxBinding for listening to text changes
    .flatMap(new Func1<CharSequence, Observable<UserPublic[]>>() {
        @Override
        public Observable<UserPublic[]> call(CharSequence query) {
            return api.searchUsers(query); // I'm using Retrofit 1.9 for network calls. searchUsers returns an Observable<UserPublic[]>
        }
    })
    .subscribe(Observers.create(
        new Action1<UserPublic[]>() {
            @Override
            public void call(UserPublic[] userPublics) {
                processResult(userPublics);
            }
        })
        , new Action1<Throwable>() {
            @Override
            public void call(Throwable throwable) {
                processError(throwable);
            }
    });

问题是,如果网络呼叫遇到错误,整个可观察的站点将停止.因此,当用户继续输入时,什么也不会发生.

如何修改此代码,以便：

>每当出现网络问题时,都会调用processError
>但是,当用户继续输入时,新的网络调用将继续发出(再次导致processResult / processError)

解决方法:

在订阅之前,请使用retryWhen()运算符并将其附加到可观察的链上.注意,retryWhen()的参数是一个带有Observable< Throwable>的函数.并返回Observable&lt ;?>.返回的类型无关紧要,因为运算符使用onNext()结果发起重试,而onError()或onCompleted()结果终止链.

这是一个等待5秒然后重试的天真应用程序：

observable
  .retryWhen( errorObservable -> errorObservable.delay( 5, TimeUnit.SECONDS ) )
  .subscribe();

这是一个较幼稚的操作,它会在超时后重试,如果发生IOException,则会失败：

observable
  .retryWhen( errorObservable -> errorObservable.flatMap( throwable -> { // (1)
       if ( throwable instanceof IOException ) {
         return Observable.error( throwable ); // (2)
       }
       return Observable.just(1); // (3)
     } )
  .subscribe();

>使用flatMap()可以将决策推迟到知道要处理的错误类型为止.
>返回的observable抛出所提供的错误或您想要更好地描述问题的其他内容.
>提供一个简单地执行onNext()的可观察对象,告诉retryWhen()运算符重新订阅原始的可观察对象.

内容总结

以上是互联网集市为您收集整理的android-RxJava：如何从flatMap运算符中的错误中恢复全部内容，希望文章能够帮你解决android-RxJava：如何从flatMap运算符中的错误中恢复所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

---