RxSwift - 为什么存在 catchError

RxSwift 有着优秀的处理错误的方案，但在讨论这个问题之前，我们不如先来思考下为什么在 RxSwift 中有 catchError 操作符。

我们先来想象几个场景：

在一个页面需要相机权限才能正常工作，但用户禁止了该权限；
在一个页面因为某种因素，请求数据失败了；
在一个提示仅限尝试输入 5 次的支付页面用户输入了 5 次密码都失败了。

这些都属于出现错误的场景。

但在讨论上述问题前，我们先来思考一下在 RxSwift 中，出现 error 会发生什么事情。

来看下面这段代码：

Observable<Int>.from([1, 2, 3, -1, 5])
    .map { value -> Int in
        if value > 0 {
            return value
        } else {
            throw CustomError.myCustom
        }
    }
    .debug()
    .subscribe()
    .disposed(by: disposeBag)

输出结果为：

-> subscribed
-> Event next(1)
-> Event next(2)
-> Event next(3)
-> Event error(myCustom)
-> isDisposed

我们可以清晰地看到在发射时到变换再到订阅的过程中，我们发射了一个 -1 ，在 map 过程中抛出了错误，导致我们收到 1 、 2 、 3 后只收到了一个 error myCustom 。

但这个场景一般不适合直接应用到开发中。举个例子，当我们点击 Button 时，进行一个网络请求，网络请求出现错误，抛出 error ，展示错误信息。整个事件结束了，当我们再次点击该 Button 时，则不会再触发网络请求。类似上述代码，5 没有被订阅者接收到。

当 Observer 收到 Observable 一个错误时，说明该 Observable 不能正常传递值了， Observer 不再对该 Observable 感兴趣，此时 Observer 取消订阅了该 Observable 。Observable 再去传递任何值 Observer 也不知道了。

为此，我们需要 catch 这个网络请求的错误，保证一切在正常的运行。而 catch 后做什么也是一件重要的事情，比如我们可以选择重试、用一个默认值替换或者阻止本次事件继续向下发射。

我们来 catch 上述发射数字的代码：

Observable<Int>.from([1, 2, 3, -1, 5])
    .map { value -> Int in
        if value > 0 {
            return value
        } else {
            throw CustomError.myCustom
        }
    }
    .catchError { (error) -> Observable<Int> in
        return Observable.just(1)
    }
    .debug()
    .subscribe()
    .addDisposableTo(disposeBag)

结果如下：

-> subscribed
-> Event next(1)
-> Event next(2)
-> Event next(3)
-> Event next(1)
-> Event completed
-> isDisposed

Observer 没有收到 error ，在前面触发 error 时，我们通过调用方法 catchError 将出现错误的 Observable 替换成了一个新的 Observable ，这里是 Observable.just(1) 。

这可能并不是我们想要的，如果我们还想接收到这个 5 怎么办？

我们需要先明确一个概念：

除非通过重新订阅，否则在一个 Observable 发射 error 后，你不再能接收到任何它发射的任何值。

上述代码中：

Observable<Int>.from([1, 2, 3, -1, 5])
    .map { value -> Int in
        if value > 0 {
            return value
        } else {
            throw CustomError.myCustom
        }
    }

这个Observable已经发射了CustomError.myCustom，我们无论如何也收不到5这个值。

但稍加修改，我们就可以收到5这个值：

Observable<Int>.from([1, 2, 3, -1, 5])
    .flatMap { value -> Observable<Int> in
        Observable.just(value)
            .map { value -> Int in
                if value > 0 {
                    return value
                } else {
                    throw CustomError.myCustom
                }
            }
            .catchErrorJustReturn(1)
    }
    .debug()
    .subscribe()
    .addDisposableTo(disposeBag)

输出结果：

-> subscribed
-> Event next(1)
-> Event next(2)
-> Event next(3)
-> Event next(1)
-> Event next(5)
-> Event completed
-> isDisposed

原因在于我们 catch 的 Observable 是：

Observable.just(value)
    .map { value -> Int in
        if value > 0 {
            return value
        } else {
            throw CustomError.myCustom
        }
    }

当这一 Observabl e出现错误时，替换成 Observable.just(1) 。

这样一来，在 flatMap 后的 Observable 变成了正常的 Observable ，我们可以继续变换值，自然最终我们可以接收到5。

我们还可以通过返回一个 Observable.empty() 忽略出现错误的值：

Observable<Int>.from([1, 2, 3, -1, 5])
    .flatMap { value -> Observable<Int> in
        Observable.just(value)
            .map { value -> Int in
                if value > 0 {
                    return value
                } else {
                    throw CustomError.myCustom
                }
            }
            .catchError { (error) -> Observable<Int> in
                return Observable.empty()
        }
    }
    .debug()
    .subscribe()
    .addDisposableTo(disposeBag)

此时输出结果为：

-> subscribed
-> Event next(1)
-> Event next(2)
-> Event next(3)
-> Event next(5)
-> Event complete

切记：在使用 catchError 时，我们要时刻明确我们 catch 的是哪个 Observable ，并将这个 Observable 替换成了什么 Observable 。

接下来我们将讨论如何创建一些定制的错误处理方法，以及如何在实际项目中处理错误的时机与方案。