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