如何将SwiftData的@Query转为Publisher并实现节流？

由于@Query是SwiftUI内置的属性包装器，没法直接用Combine的throttle处理它的更新流，我们可以通过中间层中转的方式实现节流，以下是两种可行方案：

方案一：Combine + ObservableObject 中转处理 #

通过将@Query的变化转换成Publisher，再用Combine做节流后传递给视图：

import SwiftUI
import Combine
import SwiftData

class ThrottledDataHolder: ObservableObject {
    @Published var latestData: Data?
    private var bag = Set<AnyCancellable>()
    
    init(dataStream: AnyPublisher<[Data], Never>) {
        dataStream
            .throttle(for: .seconds(1), scheduler: DispatchQueue.main, latest: true)
            .map { $0.first } // 因为fetchLimit=1，直接取唯一元素
            .assign(to: \.latestData, on: self)
            .store(in: &bag)
    }
}

struct MyView: View {
    @Query(descriptor()) var rawData: [Data]
    @StateObject private var dataHolder: ThrottledDataHolder
    
    init() {
        let dataPublisher = $rawData.eraseToAnyPublisher()
        _dataHolder = StateObject(wrappedValue: ThrottledDataHolder(dataStream: dataPublisher))
    }
    
    var body: some View {
        Text(dataHolder.latestData?.value ?? "NA")
    }
}

func descriptor() -> FetchDescriptor<Data> {
    var descriptor = FetchDescriptor<Data>(sortBy: [SortDescriptor(\.eventTime, order: .reverse)])
    descriptor.fetchLimit = 1
    return descriptor
}

方案二：自定义节流属性包装器 #

如果需要在多个视图复用节流逻辑，可以封装成自定义属性包装器：

import SwiftUI
import SwiftData

@propertyWrapper
struct ThrottledQuery<T: PersistentModel>: DynamicProperty {
    @Query private var sourceData: [T]
    @State private var throttledData: [T] = []
    private let throttleInterval: TimeInterval
    private var lastUpdateTime: Date = .distantPast
    
    init(_ descriptor: FetchDescriptor<T>, throttleInterval: TimeInterval = 1) {
        self._sourceData = Query(descriptor)
        self.throttleInterval = throttleInterval
    }
    
    var wrappedValue: [T] { throttledData }
    
    func update() {
        _sourceData.update()
        
        let now = Date()
        guard now.timeIntervalSince(lastUpdateTime) >= throttleInterval else { return }
        
        lastUpdateTime = now
        throttledData = sourceData
    }
}

使用时直接替换@Query：

struct MyView: View {
    @ThrottledQuery(descriptor(), throttleInterval: 1) var data: [Data]
    
    var body: some View {
        Text(data.first?.value ?? "NA")
    }
}

关键说明 #

• 方案一的throttle参数latest: true会保留最近一次的更新，刚好匹配你需要最新数据的需求
• 方案二通过手动记录更新时间实现节流，逻辑更轻量，适合简单场景
• 因为你的查询限制了返回1条数据，处理时直接取first或last即可

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