[RxSwift] Subject란?

안녕하세요 Foma 입니다.

 

오늘은 RxSwift 에서 아주 큰 비중을 차지하는 Subject에 대해서 알아보겠습니다!!

 

바로 시작할게요~

---

Subject란?

 

공식 홈페이지에 나와있는 내용을 해석하면

 

"Subject는 Observable과 Observable 역할을 모두 수행합니다. Observer이기 때문에 하나 이상의 Observable을 구독 할 수 있고, Observable이기 때문에 관찰한 항목을 재발송하여 통과 할 수 있으며 새 항목을 내보낼 수도 있습니다."

 

라고 되어있는데요. 

 

쉽게 말하면 옵저버블과 옵저버의 역할 둘 다 한다 라고 이해하시면 될 거 같습니다!

 

먼저 옵저버블은 뭘까요?

 

지난 시간에 "옵저버블은 데이터를 방출하는 흐름이다."라고 설명드렸습니다.

 

그렇다면 옵저버는 무엇일까요?

 

당연히 흐름(옵저버블)에서 방출한 데이터를 관찰하는 것이죠!

 

그런데 서브젝트는 이 두가지 것을 모두 하니 데이터를 방출하기도 하고 그 방출한 데이터를 관찰할 수도 있는것이죠!

 

이렇게 말하면 이해가 힘드니 예제로 알아볼게요.

---

Example

 

Observable & Observer(Subscriber)

 

옵저버블은 다음과 같이 onNext(데이터), onError,onCompleted 등을 방출하는 녀석입니다.

 

그리고 맨 아랫줄에 subcriber는 그 옵저버블을 구독하여서 데이터가 어떤 것을 방출하는 것인지 관찰하는 녀석이죠!

Subject

 

하지만 서브젝트는 아래와 같이 자기 자신을 구독하고 데이터를 방출하여 관찰할 수 있습니다.

그렇기 때문에 구독을 한 뒤에도 데이터를 맘대로 방출하고 구독한 후에 데이터를 관찰할 수 있는 것이죠!

 

 

이러한 서브젝트는 4가지 종류가 있습니다.

---

AsyncSubject

 

AsyncSubject는 아래 마블과 같이 맨 마지막의 데이터만 컴플릿이 됐을때 구독자에게 전달합니다.

 

아래와 같이 어떤 데이터를 방출되도 컴플릿이 되기전까지 아무것도 출력되지 않습니다. 그리곤 comleted이 되는 순간

 

가장 마지막의 데이터를 가져옵니다. (에러가 발생했을시엔 에러를 방출합니다.)

 

---

PublishSubject

 

PublishSubject는 AsyncSubject와 다르게 데이터가 방출되면 그 즉시 전달됩니다.

 

하지만 구독하기전 어떤 데이터를 방출한 것은 전달되지 않고 구독 이후에 방출된 데이터만 전달됩니다.

아래와 같이 Publish 1이 구독하기전에 방출됩니다. 

 

출력된 데이터를 살펴보면 구독 이전의 데이터는 전달되지 않고 구독 이후 방출된 Publish2,Publish3만 전달되게 됩니다.

 

그리고 컴플릿이나 에러가 방출되면 컴플릿과 에러를 전달하고 흐름이 끝나게 됩니다.

---

BehaviorSubject

 

BehaviorSubject는 PublishSubject와 비슷하지만 다른 점은 초기값을 가지고 있다는 것입니다.

 

PublishSubject는 아무런 데이터가 없을때 구독하면 아무것도 전달되지 않습니다.

 

하지만 BehaviorSubject는 구독이전에 아무런 데이터가 없다면 초기값으로 지정해준 데이터가 전달되게 됩니다.

 

만약 구독 이전에 데이터가 있다면 가장 마지막으로 방출된 데이터를 구독 이후에 전달하게 됩니다.

아래와 같이 BehaviorSubject에 초기값으로 Behavior 1을 지정해주고 구독하면 그 즉시 Behavior이 전달되고

 

그 뒤로 방출된 Behavior2 Behavior 3가 전달되게 됩니다.

---

ReplaySubject

 

마지막으로 ReplaySubject는 생성시 초기값으로 buffersize라는 것을 정해주어 구독이전에 방출한 데이터가 있다면

 

끝에서부터 얼만큼 가져올것인지를 정하게 됩니다. 

 

BehaviorSubject와 PublishSubject와 같이 구독 이후 방출된 데이터는 바로 전달되게 되고 컴플릿이나 에러가 발생했을때

 

컴플릿과 에러가 전달되고 흐름이 끝나게 됩니다.

 

아래와 같이 bufferSize를 2로 주고 구독 전에 Replay 1 Replay 2 Replay 3 을 방출합니다.

 

그리고 나서 구독을 하게 되면 구독 이전에 방출되었던 데이터 중 끝에서부터 2가지인 Replay2와 Replay 3이 전달되고

 

그 뒤로 방출된 데이터는 곧바로 전달되게 됩니다.

---

 

오늘은 이렇게 Subject의 개념과 총 4가지의 Subject가 어떻게 쓰이는지에 대해서 알아보았는데요.

 

아직은 저도 이렇게 이론만 공부만 하고 실제로 적용해보진 못했는데 

 

만약 적용하게되면 예시를 만들어서 포스팅하도록 하겠습니다!

 

그리고 궁금하신 내용이 있거나 틀린 점이 있다면 아래 댓글 달아주세요~~!