[RxSwift] Single

---

Single 

 

아래 코드는 observable로 만든 네트워크 통신 코드이다.

    func fetchTestData() -> Observable<TestModel> {
        return Observable.create { observer -> Disposable in
            
            AF.request(NetworkManager.testURL)
                .validate(statusCode: 200..<300)
                .responseDecodable(of: TestModel.self) { response in
                    
                    switch response.result {
                    case .success(let success):
                        observer.onNext(success)
                    case .failure(let error):
                        observer.onError(error)
                    }
                }
            
            return Disposables.create()
        }
    }

 
그러나, 위 코드에는 문제점이 하나 있다. 

버튼을 탭했을 때, fetchTestData() 메서드가 호출된다고 한다면,
해당 호출부는 flatMap을 활용해서 네트워크 요청을 하여
해당 응답값을 observable로 변환하여 subscribe를 하게 되는데,

구독과 동시에 next로 값이 잘 전달되지만,
한번 더 호출하려고 시도하는 경우!!
위의 subscribe가 dispose되지 않고 스트림이 유지된 상태로
새로운 스트림을 생성된다.
(.debug()를 통해 확인!)

디버깅을 찍어보지 않으면, 알 수 없었던 문제....

동작하는데에는 문제는 없지만,
이대로 계속 스트림이 쌓인다..? 메모리가 해제되지 않는다..?

이것이 문제.....

---

이를 해결하기 위해서는 가장 간단한 방법은
네트워크 통신에 성공했을 때, 아래와 같이 complete를 해주면 된다!

    func fetchTestData() -> Observable<TestModel> {
        return Observable.create { observer -> Disposable in
            
            AF.request(NetworkManager.testURL)
                .validate(statusCode: 200..<300)
                .responseDecodable(of: TestModel.self) { response in
                    
                    switch response.result {
                    case .success(let success):
                        observer.onNext(success)
                        observer.onCompleted() // 이렇게!!
                    case .failure(let error):
                        observer.onError(error)
                    }
                }
            
            return Disposables.create()
        }
    }

complete를 만나면 스트림은 dispose 되기 때문에 이 문제가 간단하게 해결된다.


근데, 매번 구현할 때마다 complete를 작성해주어야하고,
dispose가 제대로 되고 있는지 확인하기 번거롭다는 점..!!!!

이러한 문제를 해결해주는게 바로 Single이다!

---

위 코드는 Sinlge의 구현부 코드이다.
표시한 부분을 보면, 성공을 할 경우 next 다음에 complete가 구현되어 있는 것을 볼 수 있다.
(하나하나 complete를 챙겨주는 것이 귀찮았던 것을 Single로 해결 가능하다는 것!)
 

---

아래 코드는 Sinlge로 구현한 코드이다.

    func fetchTestDataWithSingle() -> Single<TestModel> {
        return Single.create { observer -> Disposable in
            
            AF.request(NetworkManager.testURL)
                .validate(statusCode: 200..<300)
                .responseDecodable(of: JokeModel.self) { response in
                    
                    switch response.result {
                    case .success(let success):
                        observer(.success(success))
                    case .failure(let error):
                        observer(.failure(error))
                    }
                }
            
            return Disposables.create()
        }
    }

이렇게 구현하면 방출 이후에 스트림이 dispose된다.

---

근데,,, 여기서 문제점이 하나 더 있다!!!😡


바로 error가 발생했을 경우이다.

메서드 호출하는 탭 observable 내에 네트워크 observable이 있는데,
탭 observable은 살아있고, 네트워크가 error를 보내면 그 탭도 영향을 받는다.

그런데 우리는 자식 스트림이 error를 방출하더라도 부모 스트림이 error를 받지 않아
dispose가 되지 않고, 스트림이 유지되도록 구현해야한다.

---

어떻게 해야할까?🤔

---

바로

Single<Result>를 활용하는 방법이다!

이 방법을 활용하면, error Handling과 동시에 스트림을 유지할 수 있다.

내부 코드를 살펴보면,
success와 failure 두 가지 케이스가 있다.

Result 타입으로 구현할 경우
Sinlge에서 subscribe가 끊기지 않도록!

실패 시, success를 방출하고 그 안에 명시해 놓은 Error를 담아서 방출하는 것.

enum APIError: Error {
    case invalidURL
    case unknownResponse
    case statusError
}

이렇게 Error 타입의 APIError Enum을 만들고,

    func fetchTestDataWithSingleResultType() -> Single<Result<TestModel, APIError>> {
        return Single.create { single -> Disposable in
            AF.request(NetworkManager.testURL)
                .validate(statusCode: 200..<300)
                .responseDecodable(of: TestModel.self) { response in
                    
                    switch response.result {
                    case .success(let success):
                        single(.success(.success(success)))
                    case .failure(_):
                        single(.success(.failure(.invalidURL)))
                    }
                }
            
            return Disposables.create()
        }
    }

이렇게 failure의 경우에도 Sinlge로 래핑하여 success로 해당 Error를 담아서 보내면 된다.

failure에서 

let statusCode = response.response?.statusCode
		switch statusCode {
        case 400:
             observer(.success(.failure(.missingRequiredValue)))
        case 402:
             observer(.success(.failure(.noSpacesAllowed)))
        case 409:
             observer(.success(.failure(.alreadySignedUp)))
        default:
             break
        }

이렇게 필요한 statusCode를 Switch문을 통해 방출할 수도 있다.

---

Result 타입으로 핸들링하는 방법 이외에도 flatMap 내부에서 catch문을 통해 처리도 가능하다.
(이 방법은 추후에 이어서 정리할 예정이다.)

---