RxJava 谨慎串联Observable

   <h2><strong>问题</strong></h2>    <p>RxJava提供了flatMap和switchMap两个操作符用于让我们进行Observable的串联，比如我们可以使用RxView.clicks()创建一个会发送点击事件的Observable，同时我们还有一个用于请求网络数据的Observable：</p>    <pre>  <code class="language-java">Observable<Void> loginPress(){    return RxView.clicks(findViewById(R.id.login));  }    Observable<LoginInfo> login() {    return httpApi.login();  }</code></pre>    <p>需求希望在login按钮点下之后，调用login()方法进行登陆。此时有两种写法：</p>    <ol>     <li>直接串联：</li>    </ol>    <pre>  <code class="language-java">loginPress().flatMap(aVoid -> login()).subscribe(loginInfo -> {    // 处理登录逻辑  }, throwable -> {    // 处理错误情况  });</code></pre>    <ol>     <li>分别调用:</li>    </ol>    <pre>  <code class="language-java">loginPress().subscribe(aVoid -> {    login().subscribe(loginInfo -> {      // 处理登录逻辑    }, throwable -> {      // 处理错误情况    });  });</code></pre>    <p>从代码上看，第一种方式显然是Rx更为推荐的——不打破链式调用 的方式。但在有些时候，这种方法会出现比较严重的问题：原因是，subscriber在接受到错误以后，就无法接受到之后的事件了。</p>    <p>举上面的第一个使用例子来说有两个问题：</p>    <ol>     <li> <p>如果处理登录逻辑里发生了一些意料不到的错误（比如服务器有时候成功返回了数据，但有些数据为空导致了处理逻辑出现空指针），发生错误时，错误会回调到 throwable->{} 中。之后再进行按钮点击，数据返回subscriber都接收不到了。</p> </li>     <li> <p>如果login()方法里有错误，比如网络访问异常。那么当第一次点击按钮时，subscriber会收到网络异常的错误。但如果用户再点击登录按钮，无论是否成功，我们都没有办法再次接受到登录信息，页面也无法发生跳转。</p> </li>    </ol>    <p>前者在使用 flatMap 或者 switchMap 会发生，而后者在任何情况下都有可能出现。</p>    <h2><strong>解决方案</strong></h2>    <p>使用方案2，分别调用不会产生相应的问题。但打破了RxJava的链式调用。</p>    <p>对于使用方案1，最简单的解决方案是：在遇到错误重新绑定。但这种方式的成本比较高。每个处理订阅的地方都需要进行特殊处理。</p>    <p>首先是第一个问题：</p>    <ol>     <li>如果处理登录逻辑里发生了一些意料不到的错误（比如服务器有时候成功返回了数据，但有些数据为空导致了处理逻辑出现空指针），发生错误时，错误会回调到 throwable->{} 中，但之后的任何数据返回subscriber都接不到了。</li>    </ol>    <p>这种情况出现的其实比较少。对于这种不可意料的错误，我们可以使用一个大大的try-catch把subscriber包起来，比如实现一个类似这样的类：</p>    <pre>  <code class="language-java">public class ErrorHandlerSubscriber<T> extends Subscriber<T> {    private Action1<T> onNext;    private Action1<Throwable> onError;      public ErrorHandlerSubscriber(Action1<T> onNext, Action1<Throwable> onError) {      this.onNext = onNext;      this.onError = onError;    }      @Override    public void onCompleted() {}      @Override    public void onError(Throwable e) {      if (onError != null) {          onError.call(e);          }    }      @Override    public void onNext(T t) {      try {          if (onNext != null) {              onNext.call(t);          }      } catch (Exception e) {          if (onError != null) {              onError.call(e);          } else {            // log it          }      }}  }</code></pre>    <p>在使用时：</p>    <pre>  <code class="language-java">login().subscribe(new ErrorHandlerSubscriber(loginInfo -> {      // 处理登录逻辑    } , throwable -> {      // 处理失败    }));</code></pre>    <p>这样一来，错误实际上不会被转发到Subscriber内，而只是会传到我们自定义的 throwable -> {} 里。也就不会影响实际Subscriber后续事件的接受。</p>    <p>同时，建议在 // log it 的地方将错误日志打出来，方便调试。</p>    <p>对于第二个问题：</p>    <p>2.如果login()方法里有错误，比如网络访问异常。那么当第一次点击按钮时，subscriber会收到网络异常的错误。但如果用户再点击登录按钮，无论是否成功，我们都没有办法再次接受到登录信息，页面也无法发生跳转。</p>    <p>这种情况出现出现会十分频繁，尤其在进行网络请求时。解决方案有N种</p>    <p>1.如果你不关心错误，可以使用 switchMapDelayError</p>    <p>这个关键字可以起到忽略错误的作用，但大部分情况下，我们希望在遇到错误对用户进行提示。所以如果你不关心错误是否发生的情况下，使用这个关键字进行串联是最简单的。</p>    <p>2.使用 materialize() 将next和error都包装到notification中：</p>    <p> </p>    <pre>  <code class="language-java">loginPress().flatMap(aVoid -> login().materialize()).subscrber(notification -> {    if(notification.hasValue()){      // 处理登录逻辑    } else if(notification.isOnError()) {      // 处理失败逻辑     }  });</code></pre>    <p>3.使用doOnError处理错误，同时使用onErrorResumeNext忽略错误:</p>    <pre>  <code class="language-java">loginPress().flatMap(aVoid -> login().doOnError(throwable -> {      // 处理失败逻辑     }).onErrorResumeNext(throwable -> Observable.empty())    ).subscriber(loginInfo -> {      // 处理登录逻辑    } , throwable -> {      // 处理失败    });</code></pre>    <p>这样一来，flatMap里的Observable实际上就不会发生错误，也就不会造成相应的问题了。</p>    <p> </p>    <p>来自：http://www.jianshu.com/p/647fb66d218f</p>    <p> </p>