SwiftUI中如何将Combine的Subject绑定为@Binding类型？

一、针对CurrentValueSubject的正确实现 #

你之前的扩展无法正常工作，核心问题是视图无法感知到CurrentValueSubject的数值变化——Binding的getter只是读取当前value，但没有订阅Subject的更新事件，导致Subject发送新值时视图不会自动刷新。

要解决这个问题，需要让ViewModel遵循ObservableObject协议，同时让Subject的变化触发视图的更新通知。可以通过以下两种方式实现：

方式1：扩展CurrentValueSubject（结合ObservableObject） #

import Combine
import SwiftUI

extension CurrentValueSubject where Failure == Never {
    func binding(object: ObservableObject) -> Binding<Output> {
        // 订阅Subject的变化，触发ViewModel的objectWillChange
        self
            .receive(on: RunLoop.main)
            .sink { [weak object] _ in
                object?.objectWillChange.send()
            }
            .store(in: &object.cancellables)
        
        return Binding(
            get: { self.value },
            set: { self.send($0) }
        )
    }
}

// 给ObservableObject添加存储订阅的属性
extension ObservableObject {
    fileprivate var cancellables: Set<AnyCancellable> {
        get {
            if let cancellables = objc_getAssociatedObject(self, &AssociatedKeys.cancellables) as? Set<AnyCancellable> {
                return cancellables
            }
            let newCancellables = Set<AnyCancellable>()
            objc_setAssociatedObject(self, &AssociatedKeys.cancellables, newCancellables, .OBJC_ASSOCIATION_RETAIN_NONATOMIC)
            return newCancellables
        }
        set {
            objc_setAssociatedObject(self, &AssociatedKeys.cancellables, newValue, .OBJC_ASSOCIATION_RETAIN_NONATOMIC)
        }
    }
}

private enum AssociatedKeys {
    static var cancellables = "cancellables"
}

使用示例：

class MyViewModel: ObservableObject {
    let countSubject = CurrentValueSubject<Int, Never>(0)
}

struct ContentView: View {
    @StateObject var viewModel = MyViewModel()
    
    var body: some View {
        Stepper(
            "Count: \(viewModel.countSubject.value)",
            value: viewModel.countSubject.binding(object: viewModel)
        )
    }
}

方式2：直接在ViewModel中定义Binding属性 #

如果不需要通用扩展，也可以直接在ViewModel里写计算属性，同时手动订阅Subject的变化：

class MyViewModel: ObservableObject {
    private let cancellables = Set<AnyCancellable>()
    let countSubject = CurrentValueSubject<Int, Never>(0)
    
    var countBinding: Binding<Int> {
        Binding(
            get: { self.countSubject.value },
            set: { self.countSubject.send($0) }
        )
    }
    
    init() {
        // 订阅Subject变化，通知视图更新
        countSubject
            .receive(on: RunLoop.main)
            .sink { [weak self] _ in
                self?.objectWillChange.send()
            }
            .store(in: &cancellables)
    }
}

// 视图中使用
struct ContentView: View {
    @StateObject var viewModel = MyViewModel()
    
    var body: some View {
        Stepper(
            "Count: \(viewModel.countSubject.value)",
            value: viewModel.countBinding
        )
    }
}

二、针对PassthroughSubject的处理 #

PassthroughSubject没有初始值，而@Binding要求必须有确定的初始值，所以需要额外维护一个存储变量来同步Subject的数值：

class MyViewModel: ObservableObject {
    private let cancellables = Set<AnyCancellable>()
    let textSubject = PassthroughSubject<String, Never>()
    @Published private(set) var textValue = "" // 维护同步的变量
    
    var textBinding: Binding<String> {
        Binding(
            get: { self.textValue },
            set: { self.textSubject.send($0) }
        )
    }
    
    init() {
        // 订阅Subject的变化，更新本地变量并通知视图
        textSubject
            .receive(on: RunLoop.main)
            .assign(to: \.textValue, on: self)
            .store(in: &cancellables)
    }
}

// 视图中使用
struct ContentView: View {
    @StateObject var viewModel = MyViewModel()
    
    var body: some View {
        TextField("输入文本", text: viewModel.textBinding)
    }
}

关键注意点 #

• 必须确保ViewModel遵循ObservableObject，并通过@StateObject或@ObservedObject注入到视图中，这样视图才能收到更新通知。
• 所有Combine的订阅都要在主线程接收（receive(on: RunLoop.main)），避免UI更新在后台线程导致崩溃。
• PassthroughSubject因为没有初始值，必须依赖一个本地变量来提供Binding的初始值，同时保持和Subject的同步。

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