RxSwift — 개념, 핵심 원리 및 리액티브 프로그래밍

RxSwift란?

RxSwift는 Reactive Extensions(Rx)에서 포팅된 Swift 언어용 리액티브 프로그래밍 라이브러리입니다. Observable Sequence(시간에 따라 사용 가능한 데이터 시퀀스)를 통해 비동기 및 이벤트 기반 프로그램을 설명할 수 있습니다. iOS 개발자는 중첩된 콜백 없이 네트워크 요청, UI 이벤트 및 스트리밍 데이터를 처리하기 위해 RxSwift를 사용합니다.

Observable과 Observer

RxSwift의 기반은 두 가지 핵심 프로토콜로 구성됩니다. ObservableType은 .next(value), .error(error), .completed의 세 가지 신호를 방출할 수 있는 이벤트 소스입니다. Observer는 subscribe 메서드를 통해 Observable을 구독하고 이러한 이벤트를 수신합니다. 이 모델을 Reactive Streams라고 하며 올바른 구독 시 이벤트 손실이 없음을 보장합니다.

변환 연산자

RxSwift는 스트림 작업을 위한 300개 이상의 연산자를 제공합니다. map은 각 이벤트를 변환하고, filter는 일치하는 이벤트만 통과시키며, flatMap은 중첩된 Observable을 단일 스트림으로 펼칩니다. 연산자는 체인으로 연결되어 부작용 없는 선언적 데이터 처리 파이프라인을 만듭니다.

Traits: Single, Completable, Maybe

기본 Observable 외에도 RxSwift는 특수 래퍼 유형을 제공합니다. Single은 정확히 하나의 값이나 오류를 방출하며 HTTP 요청에 이상적입니다. Completable은 값 없이 성공 또는 실패로 완료되며 쓰기 작업에 사용됩니다. Maybe는 두 시나리오를 결합하여 값 있음, 값 없음 또는 오류로 완료될 수 있습니다. 이러한 Traits는 의미를 단순화하고 코드를 자체 문서화합니다.

RxSwift에서 리액티브 프로그래밍의 작동 방식

RxSwift의 리액티브 프로그래밍은 Observer 패턴을 기반으로 합니다. ObservableSequence는 표준 라이브러리의 Sequence와 유사하지만 요소에 대한 비동기 액세스를 제공합니다. 이벤트 스트림은 연산자 체인을 통해 전달되며 각 연산자는 원본을 변경하지 않고 새 ObservableSequence를 반환합니다.

연산자 체인

RxSwift의 연산자는 하나의 ObservableSequence를 받아 새 것을 반환하는 순수 함수입니다. 예를 들어 map은 각 요소에 변환을 적용하여 새 시퀀스를 만듭니다. 연산자를 결합하여 개발자는 중간 변수 없이 데이터가 모든 처리 단계를 통과하는 파이프라인을 구축합니다.

Schedulers와 실행 스레드

Schedulers는 RxSwift에서 실행 스레드에 대한 추상화입니다. Scheduler는 코드가 실행될 스레드를 결정합니다. MainScheduler는 UI 스레드, SerialDispatchQueueScheduler는 백그라운드 큐입니다. subscribeOn과 observeOn 연산자는 각각 작업이 수행되는 위치와 결과가 처리되는 위치를 지정합니다.

RxSwift의 핵심 구성 요소

RxSwift에는 여러 기본 유형이 포함되어 있으며 각각 리액티브 파이프라인에서 고유한 작업을 수행합니다. Single은 정확히 하나의 값이나 오류를 방출하는 Observable로 네트워크 요청에 편리합니다. Completable은 값 없이 성공 또는 실패로 완료됩니다. Maybe는 Single과 Completable의 속성을 결합합니다.

Subject와 Relay

Subject는 Observer로도 작동하는 핫 Observable입니다. PublishSubject는 새 이벤트만 구독자에게 방출하고 BehaviorSubject는 마지막 이벤트와 새 이벤트를 방출합니다. Relay는 .error나 .completed를 방출하지 않는 Subject의 변형으로 스트림 연속성을 보장합니다. BehaviorRelay는 현재 값을 저장하며 상태 기반 UI에 적합합니다.

DisposeBag

DisposeBag은 Disposable 컬렉션으로, 할당 해제 시 모든 구독을 자동으로 취소합니다. iOS에서 DisposeBag은 일반적으로 UIViewController나 UIView에 추가됩니다. 화면이 닫히면 DisposeBag이 정리되어 메모리 누수와 존재하지 않는 UI 요소 액세스를 방지합니다.

RxSwift 코드 예제

다음은 map 연산자를 사용하여 문자열을 변환하는 데이터 배열에서 Observable을 생성하는 예제입니다:

let observable = Observable.of("Swift", "RxSwift", "Reactive")

observable
    .map { $0.uppercased() }
    .subscribe(onNext: { value in
        print("Received: \(value)")
    })
    .disposed(by: disposeBag)

두 번째 예제는 zip을 사용하여 두 네트워크 요청을 결합하는 방법을 보여줍니다. 연산자는 두 Observable 모두 값을 방출할 때까지 기다렸다가 결과를 튜플로 결합합니다:

let first = fetchUser(id: "123")
let second = fetchPosts(userId: "123")

Observable
    .zip(first, second)
    .observe(on: MainScheduler.instance)
    .subscribe(onNext: { user, posts in
        updateUI(user: user, posts: posts)
    })
    .disposed(by: disposeBag)

세 번째 예제는 상태를 저장하고 변경 시 UI를 자동으로 업데이트하는 BehaviorRelay 사용법을 보여줍니다. 각 state.accept() 변경은 즉시 구독자에게 전파되며 MVVM 아키텍처의 상태 패턴에 이상적입니다.

let state = BehaviorRelay(value: "idle")

state
    .subscribe(onNext: { status in
        print("Status: \(status)")
    })
    .disposed(by: disposeBag)

state.accept("loading") // Prints: Status: loading

RxSwift와 다른 접근 방식 비교

RxSwift는 전통적인 비동기 방식(Delegation, NotificationCenter, Callback)과 달리 선언적 특성과 구성 가능성에서 차별화됩니다. Combine과 달리 RxSwift는 iOS 9+를 지원하고 더 많은 연산자를 보유합니다. 하지만 Combine은 Foundation과 SwiftUI에 언어 수준에서 통합되어 새로운 Apple 프로젝트에서 이점을 가집니다.

GCD(Grand Central Dispatch)보다 RxSwift의 주요 장점은 큐를 수동으로 관리하는 대신 추상화 수준에서 데이터 스트림을 결합하고 변환할 수 있는 능력입니다. 하지만 RxSwift는 리액티브 개념을 학습해야 하므로 팀의 진입 장벽이 높아집니다.

실제로 RxSwift는 리액티브 체인이 UI 이벤트, 비즈니스 로직 및 네트워크 상호 작용을 단일 파이프라인으로 연결하는 대규모 프로젝트에서 사용됩니다. 예를 들어 트레이딩 애플리케이션에서 시세 스트림은 RxSwift를 통해 처리됩니다. 틱은 WebSocket에서 도착하고 필터링을 거쳐 시간대별로 그룹화되어 실시간으로 차트에 표시됩니다. 이 시나리오를 Delegation이나 NotificationCenter로 가독성을 유지하며 구현하기는 어렵습니다.

RxSwift의 대안으로는 Combine(iOS 13+), Swift Concurrency의 AsyncSequence(iOS 15+), Apple 플랫폼에 종속되지 않는 서드파티 라이브러리(ReactiveSwift 등)가 있습니다. 선택은 최소 지원 iOS 버전과 개발자 경험에 따라 달라집니다. 새로운 iOS 15+ 프로젝트의 경우 팀은 종종 AsyncSequence를 선택합니다. 라이브러리 설치가 필요 없고 Swift 언어의 네이티브 구조를 사용하기 때문입니다.

RxSwift를 사용한 아키텍처 패턴은 일반적으로 MVVM 또는 Clean Architecture를 따릅니다. ViewModel은 Observable 체인으로 모든 비즈니스 로직을 포함하고 View는 변환된 데이터를 구독합니다. Input-Output 패턴은 입력 이벤트(탭, 텍스트 입력)와 출력 상태(버튼 텍스트, 로더 가시성)를 분리합니다. 이 접근 방식은 테스트를 단순화합니다. ViewModel은 가상 Schedulers를 통해 UI 없이 테스트됩니다.

RxSwift는 몇 개의 화면으로 구성된 소규모 프로젝트부터 수십 개의 모듈을 가진 대규모 엔터프라이즈 애플리케이션까지 적합합니다. 대규모 프로젝트에서 리액티브 체인은 아키텍처 전체에 스며듭니다. RxProperty를 통한 UserDefaults 관찰부터 Moya(Alamofire용 RxSwift 래퍼)를 통한 네트워크 요청까지. 각 모듈은 격리되어 리액티브 인터페이스를 통해 통신하므로 구독자를 변경하지 않고 구현을 교체할 수 있습니다. 올바른 아키텍처를 사용하면 RxSwift는 기존 접근 방식보다 코드 양을 줄입니다. KVO, Target-Action 또는 NotificationCenter에 대한 보일러플레이트를 작성할 필요가 없기 때문입니다.

RxSwift는 RxDataSources와 함께 프로젝트에서 활발히 사용됩니다. RxDataSources는 UITableView 및 UICollectionView와 리액티브하게 작업하기 위한 라이브러리입니다. RxDataSources는 셀의 이전 세트와 새 세트 간의 차이를 자동으로 계산하고 애니메이션 변경을 적용합니다. 이를 통해 개발자는 beginUpdates/endUpdates의 수동 작업에서 해방되고 데이터 불일치로 인한 충돌이 제거됩니다.

RxSwift 체인 디버깅을 위한 debug() 연산자가 있습니다. 모든 이벤트(subscribe, next, error, completed, dispose)를 로깅합니다. 복잡한 리액티브 파이프라인을 개발할 때 필수적인 도구입니다. debug(String)은 로그에 표시될 식별자를 받습니다. 메모리 프로파일링을 위해 RxSwift.Resources.total은 애플리케이션에서 활성 Observable 및 Disposable의 총 수를 표시하여 DisposeBag이 정리되지 않았거나 retain cycle이 구독을 유지하는 경우 누수를 식별하는 데 도움을 줍니다. 추가 연산자 takeUntil(self.rx.deallocated)는 객체 할당 해제 시 구독을 자동으로 취소하여 누수 방지의 또 다른 계층을 제공합니다.

RxSwift 모범 사례

RxSwift 코드를 작성할 때는 구독당 단일 Observable 원칙을 따르는 것이 중요합니다. 각 ViewController는 동일한 Observable에 대해 두 개 이상의 구독을 생성해서는 안 됩니다. 이는 경쟁 상태의 위험을 줄입니다. Observable의 메모이제이션에는 share() 연산자를 사용하여 콜드 Observable을 재생 버퍼 크기 1의 핫 Observable로 변환합니다. 공유 리소스로 작업할 때는 connect()를 사용하여 방출 시작을 제어하여 모든 구독자가 첫 이벤트 전에 연결되도록 보장합니다.

RxSwift 코드 테스트는 TestScheduler를 통해 수행됩니다. 시간을 관리할 수 있는 가상 Scheduler입니다. testScheduler.createHotObservable(values)는 가상 시간별로 미리 정의된 이벤트 시퀀스를 가진 Observable을 만듭니다. testScheduler.start()는 처리를 시작합니다. TestScheduler를 사용하면 실제 지연 없이 이벤트가 어떤 순서와 가상 타임스탬프로 발생하는지 확인할 수 있어 테스트를 빠르고 결정론적으로 만듭니다.