RxAlamofire 扩展在一处处理错误

Question

以下是我执行 RxAlamofire 请求的代码

 RxAlamofire.request(request as URLRequestConvertible).validate(statusCode: 200..<300).responseJSON().asObservable()
        .subscribe(onNext: { [weak self] (response) in
                if let json = response.data {
                    let jsonResult = JSON(json)
                    let foodMenuResult = MenuResult(jsonResult)
                    self?.delegate?.showMenu(menuResult: foodMenuResult)

                }

            }, onError: {  [weak self] (error) in
               // print(error.localizedDescription)
                 UIViewController().logAPIError(error: error)
                self?.delegate?.onError(MenuViewController.REQUEST_MENU)
            },onCompleted: {})
        .disposed(by: disposeBag)

我想编写与 Observable 相关的扩展，以便我可以在一个地方处理错误，而不是在每个 onError 上编写相同的代码

我该怎么做？

Answer 1

这是最明显的解决方案：

func myRequest(_ request: URLRequestConvertable) -> Observable<T> {
    return RxAlamofire.request(request as URLRequestConvertible)
        .validate(statusCode: 200..<300)
        .responseJSON()
        .asObservable()
        .do(onError: { /* do the thing you want to always do */ })
}

我不使用 alamofire，但将上面的 T 替换为代码发出的任何类型。