RxSwift - Observable, Observer, Subscribe

Created

2023/09/15 06:39

RxSwift - Observable, Observer, Subscribe

RxSwift?

RxSwift는 비동기 프로그래밍을 관찰 가능한 순차적 형태와 함수 형태의 연산자를 통해 처리하게끔 도와준다.

→ RxSwift는 반응형 프로그래밍이기 때문에, 어떤 비동기 이벤트에 대해 관찰 가능한 형태로 만들고, 이를 관찰하는 주체가 있을 경우, 이 비동기 이벤트의 변화에 따른 전파를 받을 수 있다.

•

관찰 가능한 순차적인 형태 → Observable

•

해당 이벤트의 변화를 관찰하여 전파 받는 것 → Observer

Observable과 Observer

1. Observable

어떤 비동기 이벤트에 대해 관찰 가능한 형태 로 만든다

•

관찰 가능한 형태 → Observable

Observable 은 관찰이 가능한 흐름으로, 비동기 이벤트의 시퀀스를 생성할 수 있는 대상

RxSwift의 Observable의 정의

제네릭 클래스로 구성되어 있다.

우리가 비동기 이벤트를 어떤 관찰 가능한 형태로 만든다는 것은,

비동기 이벤트를 제네릭 타입의 Observable이란 클래스 인스턴스를 만든다는 것과 같은 것 이다.

예를들면,

가장 많이 사용하는 비동기 이벤트 UIButton 클릭 이벤트를 보자.

버튼의 클릭 이벤트가 유저에 의해 언제 발생할지 선언할 당시에는 모른다.

→ 따라서 이벤트가 들어왔을 때를 가정하고 프로그래밍을 하였다.

→ 만약 버튼이 sync 동작이었다면, 버튼이 눌릴 때까지 아무 작업도 할 수 없을 것이다.

→ 따라서 버튼은 비동기 이벤트!

근데 Reactive Programming 이란,

데이터의 흐름이 변경되었을 때 전파하는데 중점을 둔 프로그래밍이다.

따라서 여기서 데이터는 버튼,

데이터의 흐름이 변경된다는 것은 버튼이 클릭 된다는 것

그렇다면 이 버튼의 흐름 변경을 전파하기 위해선

이 버튼의 클릭 이벤트가 ‘관찰이 가능한 형태’

즉, Observable 이 되어야 한다.

정리

•

버튼의 클릭을 나타내는 UIButton의 tap 이벤트는 비동기 이벤트로,

•

데이터의 변화에 대해 관찰이 가능한 형태,

•

즉, RxSwift에서 이를 Observable 형태로 만들 수 있다.

그러면 이 버튼이 눌렸을 때 어떤 일이 일어나냐며느

버튼이 눌렸다 → 데이터의 흐름이 변경 되었다.

따라서 이 버튼의 tap event에 대한 Observable 은

버튼이 눌렸을 때(비동기 이벤트가 발생했을 때), 해당 이벤트가 발생했다는 것을 알려주기 위해 “항목(item)” 이란 것을 “방출(emit)” 한다.

(ref, https://babbab2.tistory.com/185)

Observable을 비동기 이벤트의 ‘시퀀스’를 생성할 수 있는 대상

시퀀스라고 한 이유가, 버튼이 여러번 눌리면, 그만큼 Observable은 해당 이벤트에 대한 항목을 순서대로 방출하기 때문이다.

(ref, https://babbab2.tistory.com/185)

정리하자면,

비동기 이벤트를 관찰 가능한 형태로 만든 것이 Observable 이고,

이 Observable 은 실제 비동기 이벤트가 일어났을 때, 이를 알리기 위해

해당 이벤트에 대한 항목(item)을 시퀀스로 방출한다.

그러면 이 비동기 이벤트가 방출하는 항목을 누가 받을까? → Observer

2. Observer

Observer는 Observable을 구독한다.

Observer는 내가 원하는 비동기 이벤트를 방출하는 Observable이 있을 때,

해당 ‘Observable을 구독’ 을 할 경우,

그 Observable이 비동기 이벤트가 실행되어 항목(item)을 방출 했을 때,

그 항목을 받을 수 있다!

그러면 Observer는 도대체 Observable 구독을 어떻게 하지? → Subscribe 메서드!

또한 Observer가 이 Subscribe를 통해 Observable을 구독 했을 때,

총 세 가지 클로저를 파라미터로 넘겨줘서 이벤트를 처리시킬 수 있는데

Subscribe 라는 메서드의 원형을 보면

public func subscribe(
    onNext: ((Element) -> Void)? = nil,
    onError: ((Swift.Error) -> Void)? = nil,
    onCompleted: (() -> Void)? = nil,
    onDisposed: (() -> Void)? = nil
) -> Disposable
Swift
복사

위와 같이 onNext, onError, onCompleted 라는 파라미터가 있고, 모두 타입이 클로저 타입인 것을 알 수 있다.

기존에 어떤 비동기 이벤트를 넘기고 싶을 때, 클로저로 넘겼었는데, 같은 맥락이다.

onNext:

•

Observable이 새로운 항목(item)을 방출할 때마다 이 클로저가 호출된다.

•

이때 Observable이 방출하는 항목을 클로저의 파라미터로 전달 받는다.

onError:

•

Observable은 기대하는 데이터가 생성되지 않았거나 다른 이유로 오류가 발생했을 때,

•

이 오류를 구독자인 Observer에게 알리기 위해 이 메서드를 호출한다.

onCompleted:

•

Observable은 이벤트가 종료되어 더이상 호출되지 않을 때,

•

이벤트가 완료 되었음을 구독자인 Observer에게 알리기 위해 이 메서드를 호출한다.

요약

비동기 이벤트를 관찰 가능한 형태로 만든 것 → Observable

Observable은 해당 비동기 이벤트가 발생했을 때 항목(item)을 방출함

관찰 가능한 형태인 Observable을 관찰하는 것 → Observer

Subscribe(onNext:…) 메서드 를 통해 Observable을 구독할 수 있는데,

Observable에서 항목이 방출됐을 때, 에러가 났을 때, 이벤트가 종료되었을 때에 대한 처리를 클로저로 작성하여 파라미터로 넘겨준다.

UIButton 클릭 이벤트로 보는 Observable과 Observer, Subscribe

RxSwift에는 UIKit에 대한 정보가 없다!

그래서 UI와 관련된 Reactive Programming을 하려면 RxCocoa 를 사용해야 한다.

import RxCocoa
import RxSwift
Swift
복사

UIButton은 UIKit에 속해있기 때문에, RxCocoa를 import 해서 UIButton의 tap에 대한 비동기 이벤트 처리를 다음과 같이 작성할 수 있다. (tap 이벤트 → .touchUpInside에 대한 동작)

hjButton.rx
				.tap
				.subscribe(onNext: {
						print("Observable이 항목을 방출 했다!")
				},
				onError: { error in
						print("에러가 발생했다!")
				},
				onCompleted: {
						print("해당 이벤트가 끝났다!")
				})
				.disposed(by: disposedBag)
Swift
복사