如何将Objective-C RAC风格KVO代码迁移至ReactiveSwift

以下方案针对从Objective-C ReactiveCocoa迁移到Swift原生Combine场景，混编过渡期可通过RAC桥接方法渐进迁移，无需一次性替换全量代码。

注意：原待迁移代码存在两处需要提前修正的问题：

1. 逻辑笔误：objectAWithB 组合的是 ownObjectA 和 ownObjectB 信号，但后续 reduceEach 入参声明为 ObjectA 和 ObjectC，实际应为组合 ownObjectA 和去重后的 ownObjectC，以下方案已修正该逻辑。
2. 非规范生命周期调用：原代码在initWithFrame:中手动调用awakeFromNib，迁移时需将awakeFromNib中与varQ相关的逻辑抽离为独立方法，避免xib加载时系统自动调用awakeFromNib导致逻辑重复执行。

操作符映射关系 #

RAC 与 Combine 核心操作符对应如下，可直接按表替换：

• RACObserve(target, keyPath)：对应 publisher(for: \.keyPath)，要求被监听属性标记@objc dynamic；纯Swift属性使用@Published包装器，通过$属性名获取发布者
• distinctUntilChanged：对应 removeDuplicates()，自定义类型需实现Equatable协议
• combineLatest：对应同名Combine操作符
• reduceEach：对应 map，直接对组合后的元组做转换
• switchToLatest：对应 flatMap(maxPublishers: .max(1))，限制同时只订阅最新的高阶信号
• merge：对应同名Combine操作符
• RAC(target, keyPath) = signal：对应 assign(to: \.keyPath, on: target) 或 sink 赋值，订阅需存入AnyCancellable集合持有

完整迁移代码示例 #

import UIKit
import Combine

class CustomUIButton: UIButton {
    // 原OC中@synthesize合成的属性，加@objc dynamic支持KVO监听
    @objc dynamic var objectA: ObjectA = ObjectAStore.shared.objectA
    @objc dynamic var objectB: ObjectB?
    @objc dynamic var objectC: ObjectC?
    
    // 原私有属性
    private var currentObjectB: ObjectB? {
        didSet {
            // 替代原链式RACObserve(self, currentObjectB.varQ)
            varQ = currentObjectB?.varQ
        }
    }
    @objc dynamic var varQ: Any? // 根据业务实际类型替换Any
    
    // 持有所有订阅，对象释放时自动取消订阅
    private var cancellables = Set<AnyCancellable>()
    
    override init(frame: CGRect) {
        super.init(frame: frame)
        commonInit()
    }
    
    required init?(coder: NSCoder) {
        super.init(coder: coder)
        commonInit()
    }
    
    private func commonInit() {
        // 原awakeFromNib中varQ相关初始化逻辑
        setupVarQInitialLogic()
        
        // 1. 基础属性监听
        let ownObjectA = publisher(for: \.objectA)
        let ownObjectB = publisher(for: \.objectB)
            .compactMap { $0 } // 过滤空值，对齐原RAC的nil处理逻辑
        let ownObjectC = publisher(for: \.objectC)
            .removeDuplicates() // 对应原distinctUntilChanged
            .compactMap { $0 }
        
        // 2. 组合objectA和objectC信号（修正原代码笔误）
        let objectAWithC = ownObjectA.combineLatest(ownObjectC)
        
        // 3. 从A+C映射得到objectB
        let objectBFromC = objectAWithC.map { a, c -> ObjectB? in
            a.objectBFromCIdentifier(c.identifier)
        }
        
        // 4. 外部来源objectB信号，maxPublishers: .max(1)对齐原switchToLatest逻辑
        let objectBFromExternal = objectAWithC
            .flatMap(maxPublishers: .max(1)) { a, c -> AnyPublisher<ObjectB?, Never> in
                let externalObj = ObjectExternal(objectC: c)
                return a.observedObjectA(for: externalObj)
                    .eraseToAnyPublisher()
            }
        
        // 5. 合并三路信号绑定到currentObjectB
        ownObjectB
            .merge(with: objectBFromC, objectBFromExternal)
            .sink { [weak self] objectB in
                self?.currentObjectB = objectB
            }
            .store(in: &cancellables)
        
        // 6. 监听varQ变更执行业务逻辑
        publisher(for: \.varQ)
            .sink { [weak self] _ in
                self?.handleVarQChanged()
            }
            .store(in: &cancellables)
    }
    
    // 原awakeFromNib中抽离的varQ初始化逻辑
    private func setupVarQInitialLogic() {
        // 原awakeFromNib里和varQ初始化相关的代码放这里
    }
    
    // varQ变更后的业务处理逻辑
    private func handleVarQChanged() {
        // 原varQ属性变更触发的处理逻辑放这里
    }
    
    // 若为列表重用控件，重写该方法取消旧订阅避免信号错乱
    override func prepareForReuse() {
        super.prepareForReuse()
        cancellables.removeAll()
    }
}

迁移注意事项 #

• 所有需要通过KVO监听的Swift属性必须标记@objc dynamic，否则publisher(for:)无法捕获属性变更；纯Swift类型不支持OC runtime的，改用@Published属性包装器实现监听，不要强行使用KVO。
• 优先使用sink配合[weak self]做属性绑定，避免assign(to:on:)在属性持有当前对象时产生循环引用。
• Swift是强类型语言，原RAC OC版本中宽松的nil传递逻辑需要显式通过compactMap、replaceNil等操作符处理，避免隐式解包导致的崩溃。
• 混编过渡期如果暂时无法完全替换RAC，可以调用RACSignal的bridgeToCombine()方法直接将OC信号转为Combine Publisher，渐进完成迁移，不需要一次性重构所有信号逻辑。
• 把两个初始化方法的公共逻辑抽为commonInit，确保无论通过代码创建还是xib/故事板创建，信号绑定逻辑都能正常执行。

内容的提问来源于stack exchange，提问作者Meamine