一处汉德错误的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)

我希望编写与可观察性相关的扩展，这样我就可以在一个地方处理错误，而不是在每个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替换为任何类型的代码。