안녕하세요, 이번엔 RxSwift를 다루면서 쉽게 헷갈릴 수 있는

Observable vs Observer vs Subject vs Relay 차이를 정리해보려고 합니다!

RxSwift

비동기 프로그래밍을 위한 방법 중 하나
Asynchronous Programming with Observable Stream

RxSwift는 반응형 프로그래밍이기 때문에 어떤 비동기 이벤트(버튼 탭, 키보드 등 유저의 반응)가 왔을 때,

그 이벤트를 관찰 가능한 형태로 만들고(Observable), 그 이벤트를 관찰하는 것(Observer)이 있다면 해당 변화에 따라 어떤 동작을 진행할 수 있습니다.

즉, Observable과 Observer를 통해 이벤트를 감지하여 Stream(데이터 흐름)을 통제할 수 있고, Operator로 Steam을 변경, 조작할 수 있다는 뜻입니다.

Observable

위에 언급했듯이 Observable은 비동기 이벤트를 관찰 가능한 형태로 만들어줍니다.

• 이벤트를 보내는 생산자
• 단, 이벤트를 보내기만 할 수 있고 직접 처리할 수 없습니다.
• 이벤트를 보내는 것을 방출(Emit)한다 라고 합니다.

let emailText = Observable.just("a@a.com")

Observer

Observable이 만들어준 관찰 가능한 이벤트를 관찰하고 처리하는게 Observer입니다.

• 이벤트를 받아서 처리하는 소비자
• 정확히는 Subscribe 메서드 내부에서 자체적으로 생성됩니다.
• 이벤트를 처리할 수 있지만, 직접 이벤트를 만들 수는 없습니다.

Observer는 어떻게 관찰하는걸까요?

바로 Observable를 구독(Subscribe)해서 관찰할 수 있습니다.

만약 관찰을 그만두고 싶다면 구독 취소(disposeBag)를 하면 됩니다.
dispose는 Subscribe 중인 Stream을 원하는 시기에 정리하도록 해서 메모리를 관리해줍니다.

emailText.subscribe(with: self) { owner, value in
    owner.emailTextField.text = value
} onError: { error in
    print("onError")
} onCompleted: {
    print("onCompleted")
} onDisposed: {
    print("onDisposed")
}
.disposed(by: disposeBag)

이벤트는 3가지 종류로 나눠지며 Observer는 이에 대해 각각 처리할 수 있습니다.

• Next - ex) 최신 데이터 전달
• Error - ex) 디코딩 실패, 상태 코드 오류, 네트워크 연결 유실 등
• Completed - ex) 네트워크 성공

Observable은 Next 이벤트를 방출하고 → Error 혹은 Completed 이벤트를 만나게 되면 종료가 되고 → 종료되면 disposed를 호출하여 메모리 정리

순으로 사이클이 돌아가게 됩니다.

하지만 UI 관련 이벤트는 디코딩 실패, 상태 코드 오류 같은 Error 이벤트가 날 일이 없는데 굳이 처리해야할까요? 그럴 필요가 없죠.

그래서 값 전달만 하는 Next 이벤트만 처리할 수 있고, Next 이벤트만 처리하게끔 강제할 수도 있습니다.

이는 다음에 Subscribe vs Bind vs Drive 차이를 정리하면서 다뤄보도록 하겠습니다.

Subject

이벤트를 보내면서 동시에 이벤트를 처리할 수 있습니다.

Observable은 이벤트를 보내기만 할 수 있고, Observer는 이벤트를 처리만 할 수 있는 아쉬움이 있는데 이를 보완할 수 있죠.

Subject에는 4가지 종류가 있습니다.

• BehaviorSubject - 초기값 있음
• PublishSubject - 초기값 없음
• ReplaySubject: 지정된 개수만큼 이벤트를 가지고 있다가 subscribe 직후 한번에 이벤트 전달
• AsyncSubject: Completed 이벤트가 발생하기 전까지 어떤 이벤트도 전달하지 않다가, Completed 이벤트가 발생하면 가장 마지막 값만 방출

BehaviorSubject와 PublishSubject의 차이

let num = BehaviorSubject(value: 0)
let number = PublishSubject<Int>()

가장 큰 차이는 초기값이 있냐 없냐도 있지만,

Subscribe 이전에 emit한 이벤트를 받을 수 있냐 없냐가 큽니다.

BehaviorSubject인 경우, Subscribe 이전에 onNext 로 Next 이벤트를 받게되면 가장 최근에 전달된 이벤트 하나를 받을 수 있습니다.

PublishSubject는 Subscribe 이전의 이벤트들은 모두 무시됩니다.

예를 들면 TextField의 text를 Subject가 관찰하여 2글자 미만인 경우 경고창을 띄운다고 해봅시다.

TextField의 text 중 orEmtpy는 text가 변할 때마다 값을 보내주는 이벤트인데요, 특징은 해당 TextField가 있는 뷰가 로드되자마자 이벤트를 방출하여 맨 처음엔 항상 빈 값이 들어옵니다.

만약 이 text를 BehaviorSubject가 관찰한다면 빈값이 들어옴과 동시에 이벤트를 받아 동작을 하게 되고, 당연히 빈값은 2글자 미만이므로 유저는 화면에 들어서자마자 경고창을 보게 되는 불상사가 일어나게 됩니다.

이럴 땐 Subscribe하기 전까진 동작하지 않는 PublishSubject를 통해서 방지할 수 있습니다.

Relay

Relay는 사실상 Subject입니다.

• 차이는 이벤트를 Next만 다룰 수 있냐, 없냐 입니다.

위에 '값 전달만 하는 Next 이벤트만 처리할 수 있고, Next 이벤트만 처리하게끔 강제할 수도 있습니다.' 라고 했는데요

이벤트를 방출할 수 있으면서, Next 이벤트만 처리할 수 있는 것이 바로 Relay입니다.

Next 이벤트만 처리하는 경우는 보통 UI 관련 이벤트를 처리할 때이기 때문에 Relay는 UI 처리에 적합하다고 할 수 있습니다.

UI가 Error와 Compledted 이벤트를 받게 되면 더이상 Next 이벤트를 전달 받을 수 없게 되고, 그러면 반응형의 장점이 사라지게 되겠죠.

그래서 Relay는 disposed가 되기 전까지 Subscribe가 해제되지 않습니다. disposed가 호출되는 deinit 시점이나 직접 처리를 해주어야 합니다.

Relay에는 3가지 종류가 있으며 동작방식은 Subject와 동일합니다.

• BehaviorRelay
• PublishRelay
• ReplayRelay

약간의 다른 점은 값을 할당하여 Next 이벤트를 방출할 때 사용하는 메서드가 조금 다릅니다.

• Subject - onNext
• Relay - accept

value.onNext(num)
value.accept(num)

RxSwift의 Observable vs Observer vs Subject vs Relay 차이에 대해 정리해보았는데요,

도움이 되었으면 좋겠습니다! 감사합니다.