[RxSwift] #7) Driver란 무엇인가?? [Driver와 Relay]

본 포스팅은 곰튀김님의 강의영상을 기반으로, 개인적으로 공부한 내용을 정리한 글입니다.

더욱 자세한 내용은, 강의 영상을 직접 시청하시는것을 추천드립니다! 

 

 

 

이번 글에서는 간단하게 Driver가 무엇인지에 대해서 간단하게 정리 해 보도록 하겠습니다!

글 마무리에, 5줄요약으로 간단하게 정리 한 내용도 있으니 시간이 없으신 분들은 참고해주세요.

 

 

---

 

 

이전 포스팅에서 RxCocoa를 설명 할 때 'UIKit에 Rx요소들을 적용시킨 Extentsion'이라고 설명 했습니다.

예를 들면, 아래와 같은 코드가 RxCocoa를 활용하여 UIKit에 직접적으로 Observable을 바인딩 한 예시입니다.

viewModel.itemsCount
            .map{"\($0)"}
            .observeOn(MainScheduler.instance)
            .bind(to: itemCountLabel.rx.text)
            .disposed(by: disposeBag)

 

그런데 이러한 1) UI에 직접 바인딩하는 작업의 경우에는 반드시 Main-Thread(UI Thread)에서 동작을 해야한다는 특징이 있습니다.

그렇기 때문에, .bind()를 하기 전에 .observeOn(MainScheduler.instance)를 통해서

강제로 해당 stream이 Main-Thread에서 진행되도록 해 주는 것입니다.

 

따라서, .bind()를 사용할 땐 항상 .observeOn(MainScheduler.instance)를 같이 작성 해 줘야한다는 귀찮은 점이 있습니다.

 

또한 UI동작의 경우는 데이터를 처리하던 도중 Error가 발생하면 그 순간 Stream이 끊어져 버리고,

해당 Stream은 한번 종료되면 더이상 재사용이 불가능합니다.

 

이것은 우리가 UI동작을 하다가 Error가 발생하면 이 UI는 더이상 동작하지 못한다는 것을 의미하는데,

이렇게 2) UI가 Error를 마주했을 때, Stream이 그대로 종료되는 것을 방지하기 위해서

.catchErrorJustReturn()이라는 operator를 제공합니다.

 

viewModel.itemsCount
            .map{"\($0)"}
            .catchErrorJustReturn("")
            .observeOn(MainScheduler.instance)
            .bind(to: itemCountLabel.rx.text)
            .disposed(by: disposeBag)

위 코드의 .catchErrorJustReturn("")을 통해서, Error가 발생하면 그대로 빈 문자열을 text로 전달하게 됩니다.

 

자 그렇다면, Rx를 UI에 적용하기 위해 우리는 2가지의 Operator가 반드시 필요하다는 것을 알 수 있습니다.

1) .catchErrorJustReturn()

2) .observeOn(MainScheduler.instance)

 

하지만, RxSwift는 이러한 2가지의 operator가 하는 기능들을 1개의 operator로 제공 해 주는데

그것이 바로 .asDriver()입니다.

그리고 이 .asDriver()는 .bind() 대신, .drive()라는 Operator와 함께 사용됩니다.

위에서 보여드린 코드는 아래와 같이 변경됩니다.

viewModel.itemsCount
            .map{"\($0)"}
            .asDriver(onErrorJustReturn: "")
            .drive(itemCountLabel.rx.text)
            .disposed(by: disposeBag)

위의 코드를 해석해보면,

 

[Driver로써 데이터를 보내는데, 에러가 발생하면 빈 문자열("")을 드라이브(바인딩)하고 아니라면 값을 드라이브(바인딩) 할게!]

 

라고 해석할 수 있습니다.

 

즉, Driver는 Observable의 기능은 하지만 UI동작에 특화된 Observable이라고 생각하시면됩니다!

그렇기 때문에, 아래와 같이 선언도 가능합니다!

 var 일반적인_Observable : Observable<[Menu]>
 var UI에_특화된_Observavle : Driver<[Menu]>

 

 

 

자 그렇다면, 뭔가 Observable뿐 아니라, Subject또한 이러한 동일한 이유로 UI작업을 위한 특별한 무언가가 있지 않을까요??

 

바로 그것을 Relay라고 부릅니다!

따라서 우리가 기존에 사용했던 BehaviorSubject를 BehaviorRelay로 바꿔주면

Error처리나, Completed되는 상황에 대한 신경을 쓰지 않아도 되기 때문에

.onNext() Operator가 .accept() Operator로 대체되게 됩니다!

 

class MenuListViewModel{
    
    var menusObservable = BehaviorSubject<[Menu]>(value: [])
    
    func clearAllItemSelections(){
        menusObservable
            .map {
                $0.map{ m in
                    Menu(id: m.id, name: m.name, price: m.price, count: 0)
                }
            }
            .take(1)
            .subscribe (onNext:{
                self.menusObservable.accept($0)
                // self.menusObservable.onNext($0)
                // 해당 부분에서 .onNext($0) -> .accept($0)로 변경 됨
            })
    }
}

 

 

 

<5줄 요약>

1. UI동작은 Main Thread(UI Thread)에서만 돌아가고, Error가 발생하면 Stream이 바로 끊어지는 것을 방지해야 함.

2. 이를 위해, Operator로 .asDriver()를 제공하고 .bind()대신 .drive()와 함께 사용함.

3. 즉, Driver는 UI작업에 특화된 Observable의 종류임.

4. Driver와 동일한 이유로 Subject에서 파생된 것이 Relay임.

5. 이러한 Relay는 .onNext() 대신 .accept()를 사용함. 왜냐하면 Error나 Completed를 고려하지 않아도 되기 때문임.

 

+

Subject<T>로 방출한 값이, 특정 stream에서 UI작업으로 진행된다면 .asDriver()를 사용하여 

해당 구간에서만 Observable을 Driver로 바꿔준다고 생각하면 됩니다.

 

하지만, 중간에 데이터 값의 변환 없이 처음부터 UI에 연결 할 목적이면 Driver<T>로 Observable을 생성해도 된다.

(그런데 여러 코드를 살펴 본 결과, 일단 가장 만만한(?) Subject로 생성해놓고, 필요한 Stream에서 .asDriver()를 사용하는 경우가 많은 것 같습니다....! )