android - 如何将 ContextWrapper 类与 subscribeWith 一起使用

Question

您好，我制作了 ContextWrapper 用于在单个位置进行改造错误处理，并希望在 subscribeWith 中使用它。

abstract class CallbackWrapper<T : BaseResponse> : DisposableObserver<T>() {

    protected abstract fun onSuccess(t: T)

    override fun onNext(t: T) {
        //You can return StatusCodes of different cases from your API and handle it here. I usually include these cases on BaseResponse and inherit it from every Response
        onSuccess(t)
    }

    override fun onError(e: Throwable) {
        when (e) {
            is HttpException -> {
                val responseBody = (e as HttpException).response().errorBody()
                responseBody?.let {
                    // view?.onUnknownError(getErrorMessage(it))
                }
            }
            is SocketTimeoutException -> {
                // view?.onTimeout()
            }
            is IOException -> {
                // view?.onNetworkError()
            }
            else -> {
                e.message?.let {
                    // view?.onUnknownError(it)
                }
            }
        }
    }


    override fun onComplete() {

    }

    private fun getErrorMessage(responseBody: ResponseBody): String {
        val jsonObject = JSONObject(responseBody.string())
        return jsonObject.getString(("message"))
    }
}

我正在尝试像下面这样使用它

ApiHelperImpl().doServerLoginApiCall(email, password)
                    .subscribeOn(Schedulers.io())
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribeWith(CallbackWrapper<LoginResponse> {

                    })

我想做类似 https://blog.mindorks.com/rxjava2-and-retrofit2-error-handling-on-a-single-place-8daf720d42d6 的事情有谁知道怎么做吗？

Answer 1

你需要把()在 CallbackWrapper<LoginResponse> 之后并在 kotlin 中实例化一个抽象类您必须将其称为:object: AbstractClass(...params){}

ApiHelperImpl().doServerLoginApiCall(email, password)
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribeWith(object: CallbackWrapper<LoginResponse>() {
        override fun onSuccess(r: LoginResponse) { }
    })