[RxSwift] Error Handling Operator

Network Error Handling에 대해 알아보다가 관련 operator들을 정리해보려구 합니다.

참고 : https://okanghoon.medium.com/rxswift-5-error-handling-example-9f15176d11fc

RxSwift #5 — Error Handling & Example

 

RxSwift에서는 Error Handling을 하는데 다음과 같은 방법이 있습니다.

 

1. Catch 특정 값으로 error 복구
2. Retry 재시도
3. materialize / dematerialize : Sequence 를 제어해서 처리

1. Catch

Error 발생 시, catch 내의 특정 값으로 이벤트를 발생시키고 complete 시킨다.

1) catchError

let observable = Observable<Int>
    .create { observer -> Disposable in
        observer.onNext(1)
        observer.onNext(2)
        observer.onNext(3)
        observer.onError(NSError(domain: "", code: 100, userInfo: nil))
        observer.onError(NSError(domain: "", code: 200, userInfo: nil))
        return Disposables.create { }
}

observable
    .catchError { .just(($0 as NSError).code) }
    .subscribe { print($0) }
    .disposed(by: disposeBag)

/* Prints:
    next(1)
    next(2)
    next(3)
    next(100)
    completed
*/

1, 2, 3의 출력 후에 code 100 error가 발생하고 catchError에서 Error가 .just(100)으로 바뀌어 출력되고 complete된다.

2) catchErrorJustReturn

let observable = Observable<Int>
    .create { observer -> Disposable in
        observer.onNext(1)
        observer.onNext(2)
        observer.onNext(3)
        observer.onError(NSError(domain: "", code: 100, userInfo: nil))
        observer.onError(NSError(domain: "", code: 200, userInfo: nil))
        return Disposables.create { }
}

observable
    .catchErrorJustReturn(999)
    .subscribe { print($0) }
    .disposed(by: disposeBag)

/* Prints:
    next(1)
    next(2)
    next(3)
    next(999)
    completed
*/

error가 발생했을때 Error를 무시하고 지정한 element를 반환한다. 

 

2. retry

source observable에서 error가 발생시 다시 subscribe하여 error가 발생하지 않길 바란다. 라고 소개하고 있다.

 

1) retry()

연산을 성공할때까지 계속 반복한다.

let reloadPublisher = PublishSubject<Void>()

reloadPublisher
  .flatMap {
    Api.getRepositories()
      .retry()
  }

인터넷 연결을 끊고 Api가 실패하게 되면 계속 Api.getRepositories()을 호출 할 것이다.

 

2) retry(count)

반복 호출할 count를 지정한다.

let reloadPublisher = PublishSubject<Void>()

reloadPublisher
  .flatMap {
    Api.getRepositories()
      .retry(3)
  }

let observable = Observable<Int>
    .create { observer -> Disposable in
        observer.onNext(1)
        observer.onNext(2)
        observer.onNext(3)
        observer.onError(NSError(domain: "", code: 100, userInfo: nil))
        observer.onError(NSError(domain: "", code: 200, userInfo: nil))
        return Disposables.create { }
}

observable
    .retry(2)
    .subscribe { print($0) }
    .disposed(by: disposeBag)

/* Prints:
  next(1)
  next(2)
  next(3)
  next(1)
  next(2)
  next(3)
  error(Error Domain= Code=100 "(null)")
*/

재시도 횟수를 넘어서면 error를 방출한다.

 

3) retryWhen()

재시도 하는 시점을 지정할 수 있고, 한번만 수행한다.

retry 와 다르게 마지막 Error를 이벤트로 전달하지 않는다.

let observable = Observable<Int>
    .create { observer -> Disposable in
        observer.onNext(1)
        observer.onNext(2)
        observer.onNext(3)
        observer.onError(NSError(domain: "", code: 100, userInfo: nil))
        observer.onError(NSError(domain: "", code: 200, userInfo: nil))
        return Disposables.create { }
}

observable
    .retryWhen { err -> Observable<Int> in
        return .timer(3, scheduler: MainScheduler.instance)
    }
    .subscribe { print($0) }
    .disposed(by: disposeBag)

/* Prints:
    next(1)
    next(2)
    next(3)
    (3 seconds)
    next(1)
    next(2)
    next(3)
    completed
*/

 

 

3. Materialize / Dematerialize

• RxSwift 에서 쓰이는 Event Sequence를 제어할 수 있게 해준다.
• 보통 Materialize / Dematerialize 는 함께 사용한다.
• Observable을 분해할 수 있기 때문에 신중하게 사용해야 한다.

Materialize

• Sequence 를 Event<Element> Sequence로 변환한다.

Dematerialize

• Event<Element> Sequence 를 다시 Sequence로 변환한다.

let observable = Observable<Int>
    .create { observer -> Disposable in
        observer.onNext(1)
        observer.onNext(2)
        observer.onNext(3)
        observer.onError(NSError(domain: "", code: 100, userInfo: nil))
        observer.onError(NSError(domain: "", code: 200, userInfo: nil))
        return Disposables.create { }
}

observable
    .materialize()
    .map { event -> Event<Int> in
        switch event {
        case .error:
            return .next(999)
        default:
            return event
        }
    }
    .dematerialize()
    .subscribe { event in
        print(event)
    }
    .disposed(by: disposeBag)

/* Prints
  next(1)
  next(2)
  next(3)
  next(999)
  completed
*/