时间戳

首页 > 解决方案 > RxJava - 订阅不会捕获导致崩溃的异常

kotlin - RxJava - 订阅不会捕获导致崩溃的异常

问题描述

我正在尝试订阅一个SingleSource，我已经实现了两个onSuccessAnd onErrorofsubscribe方法，这是我的代码：

disposable.add(repository
                .getUser1()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe({
                    toast(it)
                }, {
                    toast(it.message ?: "Error")
                }))

问题是当存储库中发生异常时，它不会被捕获onError

这是我的存储库实现：

class Repository(private val sp: SharedPreferences) {

    // It crashes
    fun getUser1(): Single<String> = generateUser(name, "Hello")

    // it doesn't crash
    fun getUser2(): Single<String> = Single.fromCallable { name }.flatMap { generateUser(it, "Hello") }

    private var name: String
        get() = sp.getString("user", null) ?: throw NoNameException()
        set(value) = sp.edit().putString("user", value).apply()

    private fun generateUser(name: String, message: String): Single<String> = Single.just("$message $name")

}

这是崩溃日志：

09-24 10:13:40.930 6934-6934/com.mosius.samplerxtest E/AndroidRuntime: 致命异常: 主进程: com.mosius.samplerxtest, PID: 6934 java.lang.RuntimeException: java.lang.reflect.InvocationTargetException at com.android.internal.os.RuntimeInit$MethodAndArgsCaller.run(RuntimeInit.java:503) at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:826) 原因：java.lang.reflect.InvocationTargetException at java.lang.reflect.Method.invoke(Native Method) at com.android.internal.os.RuntimeInit$MethodAndArgsCaller.run(RuntimeInit.java:493) at com.android.internal.os.ZygoteInit.main(ZygoteInit.java :826) 原因：com.mosius.samplerxtest.NoNameException：com.mosius 的 com.mosius.samplerxtest.Repository.getName(Repository.kt:17) 未提供名称。samplerxtest.Repository.getUser1(Repository.kt:10) 在 com.mosius.samplerxtest.MainActivity$onCreate$1.onClick(MainActivity.kt:24) 在 android.view.View.performClick(View.java:6597) 在 android。 view.View.performClickInternal(View.java:6574) at android.view.View.access$3100(View.java:778) at android.view.View$PerformClick.run(View.java:25881) at android.os。 Handler.handleCallback(Handler.java:873) at android.os.Handler.dispatchMessage(Handler.java:99) at android.os.Looper.loop(Looper.java:164) at android.app.ActivityThread.main(ActivityThread .java:6649) 在 java.lang.reflect.Method.invoke(Native Method) 在 com.android.internal.os.RuntimeInit$MethodAndArgsCaller.run(RuntimeInit.java:493) 在 com.android.internal.os.ZygoteInit .主要（ZygoteInit.java:826）

这两种实现有什么不同？

标签： kotlinrx-java2

解决方案

在getUser1()方法中，SingleSource还没有创建，所以它超出了 Rx 的控制来处理异常。

在第二个中，名称是在 Rx 范围内获取的，因此它可以处理异常

推荐阅读