RxJava错误处理 由于缺少异常没有处理

Question

我的问题是 rxJava 错误 由于 subscribe() 方法调用中缺少 onError 处理程序，因此未处理异常。有什么办法解决这个问题？

compositeDisposable.add(backendApi.createEphemeralKey(params)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe { response ->
            try {
                val rawKey = response.string()
                keyUpdateListener.onKeyUpdate(rawKey)`
            } catch (e: IOException) {
                keyUpdateListener
                    .onKeyUpdateFailure(0, e.message ?: "")
            }
        })

Answer 1

正如错误提示，

compositeDisposable.add(backendApi.createEphemeralKey(params)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe ({ response ->
                val rawKey = response.string()
                keyUpdateListener.onKeyUpdate(rawKey)
        }, // onError goes here as 2nd lambda parameter
        {e ->
             keyUpdateListener.onKeyUpdateFailure(0, e.message ?: "")
        })
)

这是基本的错误处理，请参考文档 Error Handling Operators

警告：您的问题太简单，已经回答，您将收到反对票和重复标记。

编辑：我认为签名差异是因为您使用的 Rx 版本。无论如何，以上内容应该与 RxJava2 一起使用，您的模块至少支持 Java 8 以支持 lambdas。