RxSwift에서 Swift Combine으로 전환하기

작성일 : 2024-05-28

RxSwift에서 Swift Combine으로 전환하기

RxSwift는 오랫동안 iOS 개발자들이 비동기 작업과 데이터 스트림 관리를 위해 사용해 온 강력한 리액티브 프로그래밍 프레임워크입니다. 그러나 애플이 공식적으로 지원하는 Swift Combine이 도입되면서, 많은 개발자들이 RxSwift에서 Combine으로의 전환을 고려하고 있습니다. 이 글에서는 RxSwift 프로젝트를 Swift Combine으로 마이그레이션하는 방법을 단계별로 설명하고, 전환 과정에서 발생할 수 있는 문제점과 해결 방안을 제시합니다.

1. 프로젝트 준비

기존 RxSwift 코드 분석

마이그레이션을 시작하기 전에, 기존 RxSwift 코드의 구조와 사용된 기능을 분석합니다. RxSwift의 주요 사용 부분을 파악하고, 이를 Combine으로 대체할 방법을 계획합니다. 특히, Observable, Observer, Subject, Schedulers 등의 사용을 주의 깊게 살펴봅니다.

Swift Combine 학습

Swift Combine의 기본 개념과 사용법을 이해하는 것이 중요합니다. Combine의 Publisher, Subscriber, Subject, Schedulers 등의 개념은 RxSwift와 유사하지만, 세부적인 구현과 API는 다를 수 있습니다. Combine에 대한 학습을 통해 마이그레이션 과정에서 발생할 수 있는 문제를 미리 예측하고 대비할 수 있습니다.

2. RxSwift에서 Combine으로 전환 단계

2.1 Observable을 Publisher로 전환

RxSwift의 Observable은 Combine의 Publisher로 대체할 수 있습니다. Observable을 생성하고 구독하는 코드를 Publisher와 Subscriber로 전환합니다.

RxSwift


swift
import RxSwift

let observable = Observable.just("Hello, RxSwift!")
observable.subscribe(onNext: { value in
    print(value)
})

Combine


swift
import Combine

let publisher = Just("Hello, Combine!")
let cancellable = publisher.sink(receiveValue: { value in
    print(value)
})

2.2 Subjects 전환

RxSwift의 PublishSubject와 BehaviorSubject는 Combine의 PassthroughSubject와 CurrentValueSubject로 대체할 수 있습니다.

RxSwift


swift
import RxSwift

let publishSubject = PublishSubject<String>()
publishSubject.onNext("Hello, RxSwift!")
publishSubject.subscribe(onNext: { value in
    print(value)
})

let behaviorSubject = BehaviorSubject(value: "Initial value")
behaviorSubject.onNext("Updated value")
behaviorSubject.subscribe(onNext: { value in
    print(value)
})

Combine


swift
import Combine

let passthroughSubject = PassthroughSubject<String, Never>()
passthroughSubject.send("Hello, Combine!")
let passthroughCancellable = passthroughSubject.sink(receiveValue: { value in
    print(value)
})

let currentValueSubject = CurrentValueSubject<String, Never>("Initial value")
currentValueSubject.send("Updated value")
let currentValueCancellable = currentValueSubject.sink(receiveValue: { value in
    print(value)
})

2.3 Schedulers 전환

RxSwift의 Schedulers는 Combine의 DispatchQueue나 RunLoop로 대체할 수 있습니다.

RxSwift


swift
import RxSwift

Observable.just("Hello, RxSwift!")
    .subscribeOn(ConcurrentDispatchQueueScheduler(qos: .background))
    .observeOn(MainScheduler.instance)
    .subscribe(onNext: { value in
        print(value)
    })

Combine


swift
import Combine

let publisher = Just("Hello, Combine!")
    .subscribe(on: DispatchQueue.global(qos: .background))
    .receive(on: DispatchQueue.main)
let cancellable = publisher.sink(receiveValue: { value in
    print(value)
})

2.4 Error Handling 전환

RxSwift의 오류 처리 연산자(catchError, retry)는 Combine의 유사한 연산자로 대체할 수 있습니다.

RxSwift


swift
import RxSwift

Observable<String>.create { observer in
    observer.onError(NSError(domain: "", code: -1, userInfo: nil))
    return Disposables.create()
}
.catchError { error in
    return Observable.just("Recovered value")
}
.retry(3)
.subscribe(onNext: { value in
    print(value)
})

Combine


swift
import Combine

let publisher = Fail<String, NSError>(error: NSError(domain: "", code: -1, userInfo: nil))
    .catch { _ in
        Just("Recovered value")
    }
    .retry(3)
let cancellable = publisher.sink(receiveCompletion: { completion in
    switch completion {
    case .finished:
        print("Finished")
    case .failure(let error):
        print("Error: \(error)")
    }
}, receiveValue: { value in
    print(value)
})

3. 문제점과 해결 방안

3.1 API 차이로 인한 문제

RxSwift와 Combine의 API는 유사하지만, 세부적인 구현에서 차이가 있습니다. 예를 들어, RxSwift의 Observable.create와 Combine의 Future는 유사한 목적을 가지지만, 사용법이 다릅니다. 이러한 차이를 이해하고 적절히 대처하는 것이 중요합니다.

3.2 메모리 관리

RxSwift는 DisposeBag을 사용하여 메모리 관리를 합니다. Combine은 AnyCancellable을 사용하여 구독을 관리합니다. DisposeBag을 Set<AnyCancellable>로 대체하여 메모리 누수를 방지할 수 있습니다.

RxSwift


swift
import RxSwift

let disposeBag = DisposeBag()

Observable.just("Hello, RxSwift!")
    .subscribe(onNext: { value in
        print(value)
    })
    .disposed(by: disposeBag)

Combine


swift
import Combine

var cancellables = Set<AnyCancellable>()

Just("Hello, Combine!")
    .sink(receiveValue: { value in
        print(value)
    })
    .store(in: &cancellables)

3.3 네트워크 요청 처리

네트워크 요청 처리 시 RxSwift의 URLSession.rx를 Combine의 URLSession.dataTaskPublisher로 대체할 수 있습니다.

RxSwift


swift
import RxSwift

let url = URL(string: "https://jsonplaceholder.typicode.com/todos/1")!
URLSession.shared.rx.data(request: URLRequest(url: url))
    .subscribe(onNext: { data in
        print(data)
    })
    .disposed(by: disposeBag)

Combine


swift
import Combine

let url = URL(string: "https://jsonplaceholder.typicode.com/todos/1")!
URLSession.shared.dataTaskPublisher(for: url)
    .map { $0.data }
    .sink(receiveCompletion: { completion in
        switch completion {
        case .finished:
            print("Finished")
        case .failure(let error):
            print("Error: \(error)")
        }
    }, receiveValue: { data in
        print(data)
    })
    .store(in: &cancellables)

4. 마이그레이션 과정에서의 테스트

마이그레이션이 완료된 후에는 반드시 충분한 테스트를 통해 새로운 코드가 기존 코드와 동일하게 동작하는지 확인해야 합니다. Combine으로 전환된 코드가 예상대로 동작하는지 확인하기 위해 유닛 테스트와 통합 테스트를 수행합니다.

결론

RxSwift에서 Swift Combine으로의 전환은 초기 학습과 코드 수정이 필요하지만, 애플의 공식 지원을 받는 Combine의 장점을 활용할 수 있는 기회를 제공합니다. 이 글에서는 RxSwift 코드를 Combine으로 마이그레이션하는 방법을 단계별로 설명하고, 전환 과정에서 발생할 수 있는 문제점과 해결 방안을 제시했습니다. Combine의 강력한 기능을 통해 더욱 효율적이고 유지보수 가능한 코드를 작성할 수 있기를 바랍니다.