gist for CleanAndroidCode article series https://medium.com/@anton.averin.dev/keep-your-droid-clean-e9c093140eb6

CleanAndroidCode :: Error Handling :: ResolvedSubscriber.kt

class ResolvedSubscriber<T> constructor(
        val resolution: Resolution,
        val onNextFunc: (T) -> Unit,
        val onCompletedFunc: () -> Unit = {},
        val onErrorFunc: (Throwable?) -> Unit = {}) : Subscriber<T>() {

    override fun onNext(p0: T) {
        if (!isUnsubscribed) {
            onNextFunc(p0)
        }
    }

    override fun onCompleted() {
        onCompletedFunc()
    }

    override fun onError(throwable: Throwable?) {
        when (throwable) {
            is HttpException -> resolution.onHttpException(throwable)
            // let your location implementation throw a custom exception on timeout, for example
//            is NetworkLocationTimeoutException -> resolution.onNetworkLocationError()
            else -> throwable?.apply { resolution.onGenericRxException(this) }
        }

        onErrorFunc(throwable)
    }

}