使用 RxJavaErrorHandler 处理全局错误

问题描述

我有下面的方法抛出异常并想在全局级别捕获该异常

public Maybe<FindProductCommand> get(ProductSearchCriteriaCommand searchCriteria) {
        LOG.info("Controller --> Finding all the products");
        return iProductManager.find(searchCriteria);
    }

根据reactivex 文档http://reactivex.io/documentation/plugins.html

为此，请扩展 class RxJavaErrorHandler 并覆盖此方法：

void handleError(Throwable e)

我正在使用带有 java 的 micronaut 应用程序并具有以下依赖项

implementation("io.micronaut.rxjava3:micronaut-rxjava3")

并尝试下面的代码

public class RxJavaExceptionHandler extends RxJavaErrorHandler{
}

无法导入 RxJavaErrorHandler

在寻找解决方案时，许多示例中都使用了以下代码

RxJavaPlugins.getInstance().registerErrorHandler(new RxJavaErrorHandler() {
        @Override
        public void handleError(Throwable e) {
            Timber.e(e.toString());
        }
    });

然而，在 RxJavaPlugins 中没有找到 getInstance().registerErrorHandler

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）