如何将Combine Publisher返回的数据传递至SwiftUI视图并完成填充？

我来给你梳理几种实用的方案，再也不用只print数据啦！这些方法都是日常开发里常用的，适配不同场景：

1. 基础方案：@Published + ObservableObject（最推荐） #

这是SwiftUI和Combine结合的标准模式，用ViewModel作为数据桥接，把Publisher的结果绑定到视图上。

步骤： #

• 定义一个遵循ObservableObject的ViewModel类，用@Published标记需要绑定的属性——这个属性变化时会自动向SwiftUI发送更新通知。
• 在ViewModel里订阅你的Combine Publisher，把收到的数据赋值给@Published属性。
• 在SwiftUI视图里用@StateObject（iOS14+）或者@ObservedObject来持有ViewModel，直接使用它的属性渲染UI。

示例代码：

import SwiftUI
import Combine

// 假设我们要获取的模型数据
struct Post: Codable {
    let id: Int
    let title: String
}

// ViewModel，负责处理网络请求和数据传递
class PostViewModel: ObservableObject {
    // @Published标记的属性，变化时会通知视图更新
    @Published var posts: [Post] = []
    @Published var errorMessage: String?
    
    private var cancellables = Set<AnyCancellable>()
    
    func fetchPosts() {
        let url = URL(string: "https://jsonplaceholder.typicode.com/posts")!
        
        URLSession.shared.dataTaskPublisher(for: url)
            .map(\.data)
            .decode(type: [Post].self, decoder: JSONDecoder())
            .receive(on: DispatchQueue.main) // 切换到主线程更新UI
            .sink(receiveCompletion: { [weak self] completion in
                if case .failure(let error) = completion {
                    self?.errorMessage = error.localizedDescription
                }
            }, receiveValue: { [weak self] fetchedPosts in
                self?.posts = fetchedPosts // 赋值给@Published属性，自动触发视图更新
            })
            .store(in: &cancellables)
    }
}

// SwiftUI视图
struct PostListView: View {
    // @StateObject用于创建ViewModel的唯一实例，生命周期和视图一致
    @StateObject private var viewModel = PostViewModel()
    
    var body: some View {
        List(viewModel.posts, id: \.id) { post in
            Text(post.title)
        }
        .alert(item: $viewModel.errorMessage) { message in
            Alert(title: Text("加载失败"), message: Text(message))
        }
        .onAppear {
            viewModel.fetchPosts() // 视图出现时触发请求
        }
    }
}

2. 轻量方案：直接在View里用.onReceive #

如果你的逻辑很简单，不想单独写ViewModel，可以直接在视图里监听Publisher，更新@State变量：

示例代码：

import SwiftUI
import Combine

struct SimpleView: View {
    @State private var currentTime: String = ""
    // 一个定时发送当前时间的Publisher
    private let timerPublisher = Timer.publish(every: 1, on: .main, in: .common)
        .autoconnect()
    
    var body: some View {
        Text(currentTime)
            .onReceive(timerPublisher) { date in
                // 接收Publisher发送的值，更新@State变量
                currentTime = date.formatted(date: .omitted, time: .standard)
            }
    }
}

3. 手动控制数据流：CurrentValueSubject/PassthroughSubject #

如果需要手动控制数据的发送时机（比如用户点击按钮后才发送数据），可以用Combine的Subject作为中间层：

示例代码：

import SwiftUI
import Combine

struct User: Codable {
    let id: Int
    let name: String
}

class UserViewModel: ObservableObject {
    // CurrentValueSubject会保存当前值，新订阅者会立即收到最新值
    private let userSubject = CurrentValueSubject<User?, Never>(nil)
    // 对外暴露一个只读的Publisher，避免外部随意发送值
    var userPublisher: AnyPublisher<User?, Never> {
        userSubject.eraseToAnyPublisher()
    }
    
    private var cancellables = Set<AnyCancellable>()
    
    func fetchUser() {
        // 模拟网络请求
        Just(User(id: 1, name: "John Doe"))
            .delay(for: .seconds(1), scheduler: DispatchQueue.main)
            .sink(receiveValue: { [weak self] user in
                self?.userSubject.send(user) // 手动发送数据到Subject
            })
            .store(in: &cancellables)
    }
}

struct UserView: View {
    @StateObject private var viewModel = UserViewModel()
    @State private var user: User?
    
    var body: some View {
        VStack {
            if let user = user {
                Text("Hello, \(user.name)!")
            } else {
                ProgressView()
            }
            Button("Fetch User") {
                viewModel.fetchUser()
            }
        }
        .onReceive(viewModel.userPublisher) { receivedUser in
            user = receivedUser // 监听Subject的Publisher，更新视图
        }
    }
}

4. iOS15+：Combine + Async/Await #

如果你更习惯用async/await，可以把Combine Publisher转换成AsyncSequence，用Task来处理：

示例代码：

import SwiftUI
import Combine

struct AsyncView: View {
    @State private var posts: [Post] = []
    
    var body: some View {
        List(posts, id: \.id) { post in
            Text(post.title)
        }
        .task {
            let url = URL(string: "https://jsonplaceholder.typicode.com/posts")!
            do {
                // 把dataTaskPublisher转成AsyncPublisher
                let posts = try await URLSession.shared.dataTaskPublisher(for: url)
                    .map(\.data)
                    .decode(type: [Post].self, decoder: JSONDecoder())
                    .values // 获取AsyncSequence
                    .first(where: { !$0.isEmpty })
                
                if let posts = posts {
                    self.posts = posts
                }
            } catch {
                print("Error: \(error)")
            }
        }
    }
}

关键注意点： #

• 一定要在主线程更新UI：Combine的大部分操作默认在后台线程，所以记得用receive(on: DispatchQueue.main)切换到主线程，避免UI更新崩溃。
• 管理订阅生命周期：用Set<AnyCancellable>存储订阅，避免ViewModel销毁后订阅仍然存在导致内存泄漏。
• @StateObject vs @ObservedObject：iOS14+优先用@StateObject，它会负责ViewModel的生命周期，避免不必要的重建。

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