RxSwift

Example

일반 비동기 처리 ex) 버튼클릭시 onLoad() 함수가 호출되어 downloadJson()으로 json 데이터 다운받고 화면에 출력

위의 과정을 다음과 같이 return을 활용하여 동기적으로 처리하고 싶음 

이렇게 처리하도록 하는 유틸리티가 바로 Rxswift (이외에도 PromiseKit, Bolt, combine등등 다양)

가짜 Rxswitf (이름만 비슷하게 직접만듬)

-> Rxswitf는 비동기로 생기는 결과값을 completion으로 전달하는것이 아니라 return으로 전달함으로써, 코드는 동기식으로 보이지만 비동기적으로 나중에 수행을 마치고 완료된 값을 변수에 할당할수 있다!

create된 observable은 subscribe함수가 호출되어야 실행된다 이후 onNext, onError, onComplete에 따라 처리되고 disposed 된다

RxSwift 이전의 비동기 프로그래밍

• Apple은 비동기 코드를 작성하는 데 많은 API를 제공.
  • NotificationCenter
     : 사용자가 장치의 방향을 변경하거나 키보드가 등장하고 사라지는 것과 같이 이벤트가 발생할 때마다 코드를 실행합니다.
  • Delegate Pattern
     : 임의의 시간에 다른 클래스 나 API에 의해 실행될 메소드를 정의합니다. 예를 들어 Application Delegate에서 새 알림이 도착할 때 수행해야 할 작업을 정의하지만 이 코드가 언제 실행되는지 또는 실행될 지 알 수 없습니다.
  • Grand Central Dispatch (GCD)
     : 작품의 실행을 추상화하는 데 도움을 준다. Serial Queue에서 순차적으로 실행되도록 코드를 예약하거나 우선 순위가 다른 여러 Queue에서 동시에 많은 수의 작업을 실행할 수 있습니다.
  • Closure
     : 클래스간에 전달할 수있는 분리 된 코드. 각 클래스가 실행 여부를 결정할 수 있습니다. 어떤 상황에서 실행할지 결정
• 하지만 API를 통한 복합적인 비동기 코드는 코드 전체가 어떤 순서로 실행되는지 파악하는것이 어렵다.

 

RxSwift

• RxSwift is a library for composing asynchronous and event-based code by using observable sequences and functional style operators, allowing for parameterized execution via schedulers. 
• RxSwift in its essence simplifies developing asynchronous programs by allowing code to react to new data and process it in a sequential and isolated manner.
• RxSwift는 코드를 새로운 데이터에 반응하며 순차적으로 처리하게 함으로써 비동기 프로그래밍을 쉽게하도록 도와줍니다.

RxSwift 구성요소

1. Observable
   
   • ReactiveX에서 Observer는 Observable을 subscription하여, Observable이 배출하는 하나 또는 연속된 항목에 반응
   • ReactiveX에서 Observable 객체는 3가지 이벤트를 배출 
     • next : 최신(다음)값을 전송하는 이벤트
     • error : Observable이 값을 배출하다 에러가 발생하면 error를 배출하고 종료시키는 이벤트
     • complete : 성공적으로 이벤트 시퀀스를 종료시키는 이벤트. Observable이 더 이상 값을 배출하지 않음
2. Subjects
   • subject는 Observer나 Observable처럼 행동하는 ReactiveX의 일부 구현체에서 사용 가능한 일종의 bridge
   • subject는 하나 이상의 Observable을 구독할 수 있는 Observer이면서 동시에 Observable이기도 하기 때문에,항목들을 하나 하나 거치면서 재배출하고 관찰하며 새로운 항목들을 배출할 수도 있다.
3. Operators
   • Operator를 사용해 Observable에 의해 방출되는 이벤트를 변환하고 처리하여 대응할 수 있다.
   • Operator는 크게 아래의 세 그룹으로 나뉜다
     • Filtering Operators : .next이벤트를 통해 받아오는 값을 선택적으로 취할 수 있다.
     • Transforming Operators : Observable을 변형하는 Operator
     • Combining Operators : Sequence들을 모으고, 각 Sequence 내의 데이터를 병합하는 Operator
4. Schedulers
   • Observable 연산자 체인에 멀티스레딩을 적용하고 싶다면, 특정 스케줄러를 사용해서 연산자(또는 특정 Observable)를 실행
   • Rx에서 Scheduler는 Dispatch Queue와 같다.

 

 

참고

https://magi82.github.io/ios-rxswift-02/

https://okanghoon.medium.com/rxswift-1-rxswift-%EC%9E%85%EB%AC%B8-67bfdbd91969as

https://ceyhununlu.medium.com/https://okanghoon.medium.com/rxswift-1-rxswift-%EC%9E%85%EB%AC%B8-67bfdbd91969