Rxjava错误处理

在RxJava中错误处理的最佳方式是什么？

原文地址：https://rongi.github.io/kotlin-blog/rxjava/rx/2017/08/01/error-handling-in-rxjava.html

在onError函数中处理错误信息

假设你有一个能产生异常的Observable，怎么处理他？第一直觉就是直接在onError函数中处理错误信息。

 userProvider.getUsers().subscribe(
    { users -> onGetUsersSuccess(users) },
    { e -> onGetUsersFail(e) } // Stop the progress, show error message, etc.            
  )

这和我们以前用的AsyncTask很类似，看起来很想一个try-catch块

这有一个大问题，如果在userProvider.getUsers()中有一个异常，例如NullpointerException会导致程序立马崩溃的，但是这确实被处理了，没有立马崩溃，错误只显示一个错误消息，或者一些其他的优雅的方式。

更糟糕的是，测试中不会有任何崩溃，而且测试会因为神秘的异常行为而失败，你不得不花费时间调试，而是能够清晰的看到堆栈信息。

预期的和意外的异常

这里先解释一下什么是预期和意外的异常。

预期的异常就好比IO，比如没有网络异常，对于这种异常，软件应当适当的给出错误提示信息。
意外的异常就是那些编程错误，他们可以发生在开发过程中，但是绝对不能出现在发布版本中，对于这种异常最好的解决方法就是崩溃，然后根据堆栈信息来解决问题。

在Java中，预期的异常主要是使用检查的异常(直接从Exception实例化)实现的，大多数意外都是使用未经检查的异常实现的，并从RuntimeException派生的。

运行时异常崩溃

如果我们想让其crash，为什么不在onError中检测是否是RuntimeException，并在onError中重新抛出。

userProvider.getUsers().subscribe(
    { users -> onGetUsersSuccess(users) },
    { e ->
      if (e is RuntimeException) {
        throw e
      } else {
        onGetUsersFail(e)
      }
    }
  )

这看起来不错，但是仍有一些缺陷

这在Rxjava2中，在应用程序中会崩溃，但是不会在测试中崩溃，在Rxjava1中，测试和应用程序都会崩溃。
除了我们想要崩溃的RuntimeException异常之外，还有更多未经检查的异常，包括错误等，很难追踪的异常。

但是主要的缺陷是：
在应用开发过程中，Rx链将会越来越复杂，在你从来没有想过要使用他的情况下，在不同的地方重复使用Observable。

Observable.concat(userProvider.getUsers(), userProvider.getUsers())
  .onErrorResumeNext(just(emptyList()))
  .subscribe { println(it) }

如果userProvider.getUsers()可观察器发出错误，会发生什么，你可能认为将两个错误都映射到一个空列表，因此将会发出两个空列表，实际上如果concat函数中的第一个参数产生错误，那么第二个就不会被执行。

所以Rxjava中的错误被设计为时致命的信号，阻止整个链条上游，他们作为意外错误执行。

结果类

如何设计，返回课观察到的预期的错误，只需让它们返回某种Result类，它将包含操作的结果或异常。这样的事情：

data class Result<out T>(
  val data: T?,
  val error: Throwable?
)

将所有预期的异常都包裹在这个类中，然后让所有意想不到的异常都使程序崩溃，避免使用onError，让Rxjava为你处理崩溃。

一些有用的代码片段

为了使你的Retrofit observables返回Result，可以使用这个方便的扩展功能：

fun <T> Observable<T>.retrofitResponseToResult(): Observable<Result<T>> {
  return this.map { it.asResult() }
    .onErrorReturn {
      if (it is HttpException || it is IOException) {
        return@onErrorReturn it.asErrorResult<T>()
      } else {
        throw it
      }
    }
}

fun <T> T.asResult(): Result<T> {
  return Result(data = this, error = null)
}

fun <T> Throwable.asErrorResult(): Result<T> {
  return Result(data = null, error = this)
}

然后，你的userProvider.getUsers()看起来就如下面这样：

class UserProvider {
  fun getUsers(): Observable<Result<List<String>>> {
    return myRetrofitApi.getUsers()
      .retrofitResponseToResult()
  }
}