[RxSwift] #1) RxSwift 개념잡기 (등장 배경 + 기본 구조)

해당 글은, 곰튀김님의 [RxSwift 4시간에 끝내기 시즌2] 영상을 보면서 스스로 공부하며 정리한 내용입니다.

아무래도 공부 한 내용을 정리하는 목적으로 작성하기 때문에, 내용에 대한 자의적인 해석이 많이 들어가 있을 수 있습니다 😭

 

따라서, RxSwift를 제대로 공부 해 보고 싶으신 분들은 곰튀김님의 강의를 직접 들으시며 공부 해 보시는것을 추천 드립니다!!!

 

 

 

 

 

---

RxSwift 개념잡기 (등장 배경 + 기본 구조)

 

example 1 소스코드 및 실행 화면

좌측의 코드를 동작 시켜서, 우측과 같은 결과를 가져오게 하고싶다. 이때, 정상적으로 동작 한다면

1. 인디케이터 UI노출

2. 시간은 계속 흘러감

3. 데이터 받아오면 text로 표현

이 3가지의 동작이 동시에 이뤄져야하지만,

 

실제로는 인디케이터도 노출이 안되고 네트워킹 동작이 일어나는 동안 상단의 타이머의 Label 변경도 정지된다.

 

그 이유를 이해하기 전에 아래의 내용을 먼저 알고 있어야하는데, 그 내용은

iOS는 따로 thread를 명시하지 않으면 main thread로 동작하고, main thread는 동기적으로 진행된다

그렇기때문에, main thread에서 json을 받아오는 네트워킹 작업 동안, 다른 모든 UI작업들은 후순위로 밀려나게 되는 것이다.

이를 해결하기 위해서는 각 작업들을 비동기로 처리 해 줘야 한다.

비동기 처리를 위해서는 global thread로 개발자가 직접 thread를 분리 해줘야한다.

또한, UI동작은 main thread에서만 동작하기 때문에 UI동작은 또다시 main thread로 분기 해줘야한다.

 

 

 

모든 작업을 비동기적으로 동작할 수 있게 global thread로 옮겨놓고, 그 중에서 UI작업들은 다시 main으로 옮겨준다

onLoad()함수를 위와같이 변경 해주면, 모든 동작이 비동기적으로 잘 동작하는 것을 볼 수 있다.

하지만, 구현부에 1) 네트워킹 작업과 2) DispatchQueue와 같은 기능이 들어가있으면

코드가 지저분 해보이니 아예 downloadJson(_ url: ) 이라는 새로운 함수로 빼버리자.

 

 

 

 

비동기 처리의 결과는 return을 할 수 없다는 에러가 발생한다.

그대로 함수로 새로 만들고 return값을 String? 타입으로 결정한 후, return을 해 주면

위와 같이, '비동기 처리의 결과는 리턴값을 제공할 수 없다' 라는 에러가 뜬다.

그렇기 때문에, 우리는 이러한 비동기동작의 결과를 다를 땐, escaping closure를 사용한다.

 

 

 

 

이렇게 비동기 작업의 결과를 다룰때는, escaping closure를 사용한다.

하지만, 이렇게 escaping closure를 사용하게 되면

1) 비동기적인 동작이 여러개 엮여 있는 경우, 중간에 에러가 발생하면 해당 부분을 발견해서 처리하기 힘들고

2) 코드가 매우 더러워진다.

 

 

 

진짜 보기만 해도 어지럽고 더럽다,,,,,,우웩

그래서 사람들은 '이런 비동기적으로 처리된 결과를 그냥 리턴값으로 전달 해 줄 수 있는 방법은 없을까?' 라는 고민을 하였고

그것을 해결 해 주기 위한 유틸리티가 나왔는데, 그 중 하나가 RxSwift이다.

 

 

 

즉, RxSwift는 [비동기적으로 생기는 데이터 (Observable<T>)]를 [해당 데이터가 필요한 시점에 처리(.subscribe)]를 가능하게 해주는 유틸리티 이다.

 

자 이것으로 RxSwift 설명을 마치도록 하겠다!!!!!

.

.

.

.

.

사실 맞는 말이긴 하지만,

밥을 하는데 어떻게, 쌀과 물이 필요하다는 것만 알면 맛있는 밥을 지을 수 있으랴~

원리와 방법을 알아야 맛있는 밥이 나오지!!!

 

우선 가장 기본적인 RxSwift의 동작원리를 알아보자

 

1. [Observable] 형태로 감싸는 데이터는 '나중에 생기는 데이터' 라는 것!!

2. 또한, '나중에 생긴 데이터를 사용' 하기 위해서는 [.subscribe]를 호출하면 된다.

3. 그러면, event가 발생하는데, 3가지로 나뉜다. (.next / .completed / .error)

일반적 리턴값은 String?이지만 나중에 나오는 결과 이므로 Observable<String?>을 리턴시킨다. 또한, 나중에 생긴 데이터를 다루기 위해 .subscribe를 호출하였다.

 

 

 

다시한번 강조하지만, 우리가 RxSwift를 배운다는 것은

1. 비동기로 생기는 데이터를 Observable로 감싸서 리턴하는 방법

2. Observable로 오는 데이터를 받아서 처리하는 방법

이 2가지를 공부 한다는 것임을 유의하자. (즉, 이 두가지만 잘 다루면 RxSwift는 마스터 할 수 있다는 말~)

 

그렇다면, 위의 2가지를 적용하여 실제 코드를 작성 해보자

---

1. 비동기로 생기는 데이터를 Observable로 감싸서 리턴하는 방법

가장 기본적인 Observable 생성

URLSession을 사용하여 Observable을 create 해보았다.

위를 보면 알 수 있지만, error가 발생하면 emit.OnError로 해당 error를 보내주고, data가 제대로 있으면 해당 데이터를

String으로 변환하여 onNext로 뿌려준다.

이후 동작이 마치면 onCompleted로 Observable을 deinit 해준다.

 

깔끔하게 Observable의 생명주기를 정리 해 보자면

1. Create

2. Subscribe

3. onNext

4. onCompleted / onError

5. Disposed

 

위의 순서를 보면 짐작 할 수 있지만, Observable을 Create한다고 해서 해당 Observable이 바로 동작 하는 것은 아니다.

Observable이 subscribe가 되어야만, 비로소 동작들을 실행한다.

 

또한 onNext가 모두 진행 되고, onCompleted / onError에 의해 Disposed된 Observable은 절대 재사용되지 않는다.

->  Observable에 대한 subscribe를 다시 진행해야만, 사용이 가능함

이미 죽은 놈 건드리지 말고, subscribe를 통해 새 생명을 불어넣어주자~

---

2. Observable로 오는 데이터를 받아서 처리하는 방법

데이터를 받아서 처리하는 가~~장 기본적인 형태

위 그림은 Observable을 처리(.subscribe)하는 가장 기본적인 구조이다.

기본적으로, subscribe를 통해서 event를 받고 .next / .error / .completed 를 처리할 지 결정하면 된다.

그리고 subscribe의 리턴타입인 Disposable에 대한 dispose()를 호출하여 마무리한다.

 

 

 

 

 

+ 추가적으로, closure를 사용하면서 observable에 대한 순환참조가 발생하게되는데, 이 순환 참조는 event라는 observable이 종료가 되어야 사라진다. 이때, 위에서 설명 했듯이 observable의 종료 조건은 onCompleted / onError / Disposed 되었을 때 이다.

그럼, 저 때를 기다리면 되지 않느냐 라고 생각할 수 있지만....그냥 맘 편하게 event 앞에 [weak self] 붙이도록 하자,,,,

이렇게 [weak self]를 사용하여, 간단하게 순환참조를 방지할 수 있다.