Thanks to @fimuxd 🖤

https://github.com/ReactiveX/RxSwift
https://github.com/fimuxd/RxSwift

---

Section IV: Intermediaate RxSwift/RxCocoa

에러관리

RxSwift 에서 에러관리는 프레임워크 중 하나. (= 제공해준다.)
해결 방법은 catch와 retry. 두 가지 방법.
– catch : defaultValue 로 error 복구
– retry : 제한적 또는 무제한으로 재시도


catch
– Swift의 do-try-catch 와 비슷.

1. func catchError(_ handler:) -> RxSwift.Observable
– Error가 발생하면 Error가 발생하기 전의 값을 반환.

2. func catchErrorJustReturn(_ element:) -> RxSwift.Observable
– Error를 무시하고 이전에 선언해둔 값을 반환.
– Error의 내용에 상관없이 모든 에러에 대해 동일한 값이 반환된다. 1.에 비해서 제한적.

사용
– 에러는 Sequence가 진행되는 과정에서 발생한다. 에러가 발생했을 때 별도의 처리가 없다면 그대로 정지되고 사용자에게 Error가 전달되게 된다.

let weather = cityNameTextField.rx.controlEvent(.editingDidEndOnExit)
.asObservable()
.map { [weak self] in self?.cityNameTextField.text }
.filter { ($0 ?? "").count > 0 }
.flatMapLatest { APIClient.shared.requestWeather(city: $0!) }
.catchError { [weak self] error in // 💫
    if let currentWeather = self?.currentWeather {
        return Observable.just(currentWeather)
    } else {
        return Observable.just(Weather.empty)
    }
}

retry
– sequence 에서 발생한 에러에서 retry 가 사용되면 sequence는 스스로를 계속 반복한다.
– 유저가 직접 재시도할 때의 부작용을 막기 위해서 권장되는 방법. (네트워크 에러의 경우 활용 가능!)

let weather = cityNameTextField.rx.controlEvent(.editingDidEndOnExit)
.asObservable()
.map { [weak self] in self?.cityNameTextField.text }
.filter { ($0 ?? "").count > 0 }
.flatMapLatest { APIClient.shared.requestWeather(city: $0!) }
.retry(3) // 💫
.catchError { [weak self] error in
    if let currentWeather = self?.currentWeather {
        return Observable.just(currentWeather)
    } else {
        return Observable.just(Weather.empty)
    }
}

– .retryWhen
– 특정한 에러일 때의 retry 조건을 정의할 수 있다.






Custom Error

enum APIError {
    case serverError
    case unknowError
}

func testError(session: URLSession, request: URLRequest) {
    session.rx.response(request: request).map { response, data in
        if 200 ..< 300 ~= response.statusCode {
            return try JSON(data)
        } else if 400 ..< 500 ~= response.statusCode {
            throw APIError.serverError
        } else {
            throw APIError.unknowError
        }
    }
}

---

Creating Custom Reactive Extensions

extension Reactive where Base: URLSession {
    func response(request: URLRequest) -> Observable<(HTTPURLResponse, Data)> {
        Observable.create { observer in
            let task = self.base.dataTask(with: request) { data, response, error in
                guard let response = response, let data = data else {
                    observer.on(.error(error ?? RxCocoaURLError.unknown))
                    return
                }

                guard let httpResponse = response as? HTTPURLResponse else {
                    observer.on(.error(RxCocoaURLError.nonHTTPResponse(response: response)))
                    return
                }

                observer.onNext((httpResponse, data))
                observer.on(.completed)
            }

            task.resume()

            return Disposables.create(with: task.cancel)
        }
    }
}

– Reactive extension 은 프로토콜 extension.
– .rx 를 URLSession 뒤에 붙일 수 있게 해준다.
– 코드 예에서는 URLSession 이지만 다른 class 에서도 물론 가능 !