Rxswift + Moya + Moya-ObjectMapper Обработка ошибок

Я использую Moya и Moya-ObjectMapper с Rxswift для выполнения сетевых запросов.

Мой сетевой запрос ниже.

let provider = RxMoyaProvider<APIClient>()

requestHospitalButton.rx_tap
    .withLatestFrom(hospitalCode)
    .flatMapLatest { [unowned self] code in
        self.provider.request(.Hospital(code: code))
     }
     .mapObject(Hospital)
     .subscribe { [unowned self] event in
         switch event {
         case .Next(let hospital):
             // success
         case .Error(let error):
             // error
         default: break
         }
     }
     .addDisposableTo(rx_disposeBag)

Если возникает ошибка, мой запрос в больницу Observable прекращается, и я больше никогда не смогу сделать запрос в больницу.

Как я могу повторить запрос в больницу при нажатии requestHospitalButton?


swift rx-swift reactivex moya
person c8112002    schedule 05.09.2016    source источник

Ответы (1)


arrow_upward
1
arrow_downward

Вы должны использовать retryWhen, который задокументирован :

extension ObservableType {

    /**
    Repeats the source observable sequence on error when the notifier emits a next value.
    If the source observable errors and the notifier completes, it will complete the source sequence.
    - seealso: [retry operator on reactivex.io](http://reactivex.io/documentation/operators/retry.html)

    - parameter notificationHandler: A handler that is passed an observable sequence of errors raised by the source observable and returns and observable that either continues, completes or errors. This behavior is then applied to the source observable.
    - returns: An observable sequence producing the elements of the given sequence repeatedly until it terminates successfully or is notified to error or complete.
    */
    public func retryWhen<TriggerObservable: ObservableType>(_ notificationHandler: @escaping (Observable<Swift.Error>) -> TriggerObservable)
        -> Observable<E> {
            return RetryWhenSequence(sources: InfiniteSequence(repeatedValue: self.asObservable()), notificationHandler: notificationHandler)
    }
}
person solidcell    schedule 05.09.2016