[RxSwift] Observable 간단하게 알아보기

안녕하세요 Foma 입니다!

 

저번 시간에 Reactive X는

"옵저버블 흐름을 사용하는 비동기 프로그래밍을 위한 API"

라고 소개드렸습니다.

 

소개에 나와 있다시피 Observable 이라는 개념은 가장 핵심이 되는 것인데요.

 

그래서 오늘은 Observable에 대해서 알아보겠습니다.

---

Observer Pattern

먼저 Reactive X는 옵저버 패턴을 사용합니다.

 

옵저버 패턴이란 Observable을 Observer가 구독하고 Observable이 어떤 상태를 방출하였을 때

 

Observer에게 알림을 보내는 것이죠.

 

이것은 유튜버가 구독자에게 알림을 보내는 방식으로 이해하시면 편할거같아요.

 

Observable이 알림을 보내는 방식은 3가지가 존재합니다.

 

OnNext -> 데이터가 발생했을때

 

OnError -> 에러가 발생했을때

 

OnComplete -> 모든 이벤트가 완료되었을때

Example

아래와 같이 1,2,3의 데이터를 방출하는 Observable과 그것을 구독하는 Subcriber를 만들어줬습니다.

 

이것을 실행시켜보면 아래와 같이 방출된 데이터가 차례대로 출력되는 것을 볼 수 있습니다.

마블로 확인하면 아래와 같은 그림입니다. 아직 Complete가 되지 않았기 때문에 Observable이 계속 흐르고(?) 있죠.

여기서 Observable에 onCompleted를 방출시켜 흐름을 완료시켜주면

아래와 같이 completed가 출력되는 것을 볼 수 있습니다.

만약 데이터를 방출시키는데 중간에 에러가 발생한다면 어떻게 될까요?

 

아래와 같이 데이터를 1과 2를 방출시키고 3을 방출하기 전에 에러를 방출시켰습니다.

 

그러면 아래와 같이 1과 2가 출력되고 그 뒤로는 에러가 출력된 것을 볼 수 있습니다.

 

이것은 에러가 난 뒤에는 데이터가 방출되지 않으며 심지어 Complete도 방출되지 않습니다.