检查项目依赖的retrofit和rxjava版本是否一致，大多数java.lang.IllegalStateException: Fatal Exception thrown on Scheduler.Worker thread.都是由于这个问题造成的
创新互联公司始终致力于在企业网站建设领域发展。秉承“创新、求实、诚信、拼搏”的企业精神，致力为企业提供全面的网络宣传与技术应用整体策划方案，为企业提供包括“网站建设、成都响应式网站建设公司、手机网站建设、微信网站建设、微信小程序、购物商城网站建设、平台网站建设秉承"和谐、参与、激情"的文化，与客户和合作伙伴齐心协力一起成长，共同发展。
2. compile 'com.squareup.retrofit2:adapter-rxjava:2.1.0'
compile 'com.squareup.retrofit2:retrofit:2.1.0'
把版本调成一样的，重新gradle一下应该就阔以了
1. 首先定义带泛型的返回结果，Retrofit API 的原生结果映射为这种形式：
class ResultT {
String ResultMessage;
int ResultCode;
T Data;
}
2. 处理错误的方法和 @朱诗雄 前辈方法差不多，放到作为静态方法放到 RetroUtil 里，这里 ApiException 为自己定义的一个异常，放入错误码和错误信息（错误码不止一个）：
static T ObservableT flatResult(ResultT result) {
return Observable.create(subscriber - {
switch (result.ResultCode) {
case Constants.SUCCESS_CODE:
subscriber.onNext(result.Data);
break;
case Constants.ERROR_CODE:
subscriber.onError(new ApiException(result.ResultCode, result.ResultMessage);
break;
default:
// ...
}
subscriber.onCompleted();
}
});
}
3. 在 API 包装类对于上述 ResultT 格式的返回结果，统一调用 flatMap(RetroUtil::flatResult) 后的 API。这样每个 API 的返回结果就是 ObservableData 的形式并且在 errorHandler 中统一处理错误了。
// 接口方法
ObservableResultUser getUserInfo();
// 包装后的方法
ObservableUser getUserInfo() {
return mApi.getUserInfo.flatMap(RetroUtil::flatResult);
}
// 调用时
apiWrapper.getUserInfo()
.subscrible(user - {
// 处理正常逻辑
}, error - {
// 处理错误逻辑和异常，这里封装时通常也会统一处理，
// 提供一个默认的 Action1Throwable 参数，弹出
// throwable 的 message 打印日志等
});
RxJava要比EventBus的应用更广泛，EventBus仅仅是作为一种消息的传递工具，但是RxJava里面几乎可以做任何事情。
如果是Android开发的话，可以使用RxAndroid，这是对RxJava的一个扩展，结合sqare公司的retrofit可以很轻松的完成网络的访问。
我们知道，在Android中异步操作一般使用AsycTask来完成，但是AsycTask有很多缺点，如不能方便的终止任务的执行等。
RxAndroid完全可以替代AsycTask来完成各种异步操作，而且还有BindActivity和BindFragment方法，你根本不需要考虑异步操作时的Activity和Fragment的生命周期问题，还有更加强大的的链式调用，可以使程序很简洁。
EventBus有个缺点就是凡是使用了EventBus的类都不能进行混淆了，否则Evnetbus就找不到OnEvent方法了。
以上，推荐使用RxAndroid。
