(RxSwift) Error 다루기, Retry, Catch

Observable -> Subscriber 로 ErrorEvent가 전달되면, 구독이 종료되고 더 이상 이벤트를 전달받지 못하게 된다. 그렇게되면 더 이상 새로운 이벤트에 대해서 핸들링할 수 없게된다.
일반적인상황에서 Observable은 Network를 요청하고, Subscriber는 UI를 업데이트한다. 이때 ErrorEvent가 발생하면 구독이 종료되어 더 이상 UI를 업데이트 하지 못하게된다.
이러한 문제를 catch 혹은 retry를 통해서 해결할 수 있다.

Catch (Operator)

CatchError를 사용하면 Next, Completed 이벤트는 평소대로 구독자에게 전달한다. 하지만 ErrorEvent가 발생하면 새로운 Observable을 생성하여 구독자에게 전달해주거나, 기본값을 전달하여 UI 업데이트가 끊어지지 않도록 할 수 있는 연산자이다.

enum TError: Error{
    case testError
}
let bag = DisposeBag()
let subject = PublishSubject<Int>()
let recovery = PublishSubject<Int>()

subject
    .catch({ error in
        recovery // 에러 이벤트가 발생했을때, 새로운 옵저버블을 반환해준다. (원래 옵저버블과 새로운 옵저버블이 교체된다.)
    })
    .subscribe { print($0) }
    .disposed(by: bag)

subject.onNext(1)
subject.onError(TError.testError) // 이시점에서 구독이 종료된다.

subject.onNext(2) // 구독이 종료되었기 때문에 반응 없음
recovery.onNext(188) // catch로 받은 새로운 observable

catchAndReturn

let bag = DisposeBag()

enum MyError: Error {
    case error
}

let subject = PublishSubject<Int>()

subject
    .catchAndReturn(-199)
    .subscribe { print($0) }
    .disposed(by: bag)

subject.onNext(100)
subject.onError(MyError.error) // 지정해둔 기본값이 return 되고 completed 이벤트를 방출한다.
subject.onNext(100) // 더 이상 이벤트가 방출되지 않는다.

Retry

CatchError와 마찬가지로 Next, Completed 이벤트에서는 달라지는게 없지만, ErrorEvent가 발생하면 Subscriber에게 전달하지 않고 다시 실패했던작업을(주로 network 작업) 시도하게된다. 이때 재시도 횟수도 제한이 가능하다.

let bag = DisposeBag()

enum MyError: Error {
    case error
}

var attempts = 1

let source = Observable<Int>.create { observer in
    let currentAttempts = attempts
    print("#\(currentAttempts) START")

    if attempts < 3 {
        observer.onError(MyError.error)
        attempts += 1 // 3이 넘어갈때까지 재시도를 하면 아래의 onNext이벤트가 전달되게된다.
    }

    observer.onNext(1)
    observer.onNext(2)
    observer.onCompleted()

    return Disposables.create {
        print("#\(currentAttempts) END")
    }
}

source
    .retry(5)
    .subscribe { print($0) }
    .disposed(by: bag)

retry(When:)

기본적으로 ErrorEvnet가 발생하면 retry를 시도한다는건 같지만, retry를 바로하는게 아니라 언제할지 시점을정해줄 수 있다.

let bag = DisposeBag()

enum MyError: Error {
    case error
}

var attempts = 1

let source = Observable<Int>.create { observer in
    let currentAttempts = attempts
    print("START #\(currentAttempts)")

    if attempts < 3 {
        observer.onError(MyError.error)
        attempts += 1
    }

    observer.onNext(1)
    observer.onNext(2)
    observer.onCompleted()

    return Disposables.create {
        print("END #\(currentAttempts)")
    }
}

let trigger = PublishSubject<Void>()

source
    .retry(when: { _ in
        trigger
    })
    .subscribe { print($0) }
    .disposed(by: bag)



trigger.on(.next(())) // 이 시점에서 retry를 시도하게된다.