以下是我执行 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 上编写相同的代码
我怎样才能做到这一点?