Android Rxjava 背压解决，及找不到哪报OnErrorNotImplementedException

使用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() {
            @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() {
            @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类