Расширение RxAlamofire для ошибки hanlde в одном месте

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 в приведенном выше типе, который испускает код.