[iOS] RxSwift - Observables 생성과 구독, 생명주기, operator

💡 ReacitveX - Observable 

• ReactiveX 에서 Observer 는 Observable 을 subscribe 한다.
• observer 는 Observable 이 방출하는 아이템 (단일 혹은 시퀀스)에 응답한다. 
• 이를 통해 동시성(concurrency) 연산이 가능하다.
• Observable 이 객체를 방출할 때까지 기다릴 필요 없이, 객체가 방출되면 그 시점을 감시하는 관찰자를 observer 내에 두고, 그를 통해 알림을 받는다.

 

✔︎ Observer 생성 & 구독

비동기 모델에서는 아래와 같은 흐름대로 코드가 실행된다.

 

• async method 호출로 결과를 리턴받고, 필요한 동작을 처리하는 method 를 정의한다. * Observer 의 일부
• Observable 로 비동기 호출을 정의한다.
• subscribe 를 통해 observer 를 Observable 객체에 연결시킨다.
• onNext event 발생시 수행할 코드를 구현한다.

🌱 Observable 의 생명주기
1. Create 
2. Subscribed 
3. Next (수행)
- - - 끝 - - - 
4. Completed / Error 
5. Disposabled

 

✔︎ Observable 을 생성할때 이용하는 operator

• Observable 을 생성하는 기본 operator
• observer 의 onNext, onError, onCompleted 메소드를 적절히 호출해 작성할 수 있다.
• Observable 생성 후, 전달할 데이터를 onNext(data) 를 통해 전달하고, onCompleted() 를 통해 종료한다. 
• Error 처리가 필요할 경우 onError(error) 를 통해 전달한다.
• observer 의 onCompleted 혹은 onError 메소드가 한번은 호출되어야 한다.

---

 

• Observables.create 와 onNext(data) 를 한 번에 사용할 수 있는 operator 이다.
• 데이터가 단 하나만 있을 경우 Just 를 이용한다. 
• 데이터 한개를 전달하는 것이지만, 배열 하나를 전달할 수도 있다. 이 때에는 event 가 한 번 발생한다.

---

 

• Observables.create 와 onNext(data) 를 한 번에 사용할 수 있는 operator 이다.
• 데이터를 여러개, 각 이벤트로 전달할 경우 From 을 이용한다.
• From으로 전달되는 데이터는 array 타입으로, 각 배열의 원소가 데이터로 여러번의 event 로 전달된다.

---

✔︎ 그 외의 Create 관련 operator 

• Empty :: 비어있는 observable 을 전달하고 싶을 때 이용한다.
• Never :: 절대 observable 을 전달하지 않을 경우 이용한다.
• Throw :: observable 을 생성하고, error 를 전달할 경우 이용한다.