Как организовать взаимодействие старого реактивного кода с новым Combine-кодом?

В реальных проектах часто встречается ситуация, когда часть приложения написана на RxSwift, а новая — на Combine. Полная перепись кода обычно невозможна, поэтому используют переходные решения.

Основной подход

Сначала выделяются границы взаимодействия:

• слой сети

• слой бизнес-логики

• ViewModel

На этих границах создаются адаптеры.

Адаптация RxSwift в Combine

Один из подходов — обернуть Rx-поток в Future:

func loadData() -> AnyPublisher<Data, Error> {
    Future { promise in
        rxObservable
            .take(1)
            .subscribe(
                onNext: { promise(.success($0)) },
                onError: { promise(.failure($0)) }
            )
            .disposed(by: disposeBag)
    }
    .eraseToAnyPublisher()
}

Адаптация Combine в RxSwift

Обратная ситуация решается через callback или Observable.create, где Combine-подписка управляется вручную.

Практическая стратегия

1. Новый код писать только на Combine

2. Старый RxSwift-код не переписывать без необходимости

3. Минимизировать количество точек пересечения

Вывод

Лучший подход — постепенная миграция с четкими границами и адаптерами между RxSwift и Combine.