使用Rxjava 时，若是发送事件的速度快于处理观察者处理事件速度，（如循环发送事件onNext("")）,就会出现背压问题
一、背压问题解决
1，解决的策略有
- onBackpressureBuffer()：若时缓存满的话，还是会报异常
- onBackpressureDrop()：观察者处理不过来时，将事件抛弃
- onBackpressureLatest():和onBackpressureDrop一样，不过缓存最新的一条数据
如果对于发送的事件可以忽略，建议使用onBackpressureDrop()
2，在.subscribe(); 内实现对异常的处理
???????
?
二、发现哪里报OnErrorNotImplementedException
使用rxjava2-extensions 库，在build.gradle 的dependencies 内添加，再进行Syc project
implementation "com.github.akarnokd:rxjava2-extensions:0.20.10"
添加rxjava2-extensions 库后，在Application 的onCreate()内，引用代码
注：使用Rxjava3 则使用Rxjava3的事件查找即可，Rxjava2也是
RxJavaAssemblyTracking.enable();
//Rxjava3
RxJavaPlugins.setErrorHandler(new Consumer<Throwable>() {
@Override
public void accept(Throwable throwable) throws Throwable {
RxJavaAssemblyException exception = RxJavaAssemblyException.find(throwable);
if (exception != null) {
Log.e("TAG", "Rxjava3Exception: "+ exception.stacktrace());
}
throwable.printStackTrace();
}
});
//Rxjava2
io.reactivex.plugins.RxJavaPlugins.setErrorHandler(new io.reactivex.functions.Consumer<Throwable>() {
@Override
public void accept(Throwable throwable) throws Exception {
RxJavaAssemblyException exception = RxJavaAssemblyException.find(throwable);
if (exception != null) {
Log.e("TAG", "Rxjava2Exception: "+ exception.stacktrace());
}
throwable.printStackTrace();
}
});
注：AndroidManifest.xml引用自定义的Application类
