时间戳

首页 > 解决方案 > 如何使用组合来分配从核心数据获取请求返回的元素数量？

swift - 如何使用组合来分配从核心数据获取请求返回的元素数量？

问题描述

我希望我的应用程序定期获取新记录并将它们存储在核心数据中。我的 UI 上有一个标签，应该显示特定记录的元素数量，并且我希望随着更多记录添加到数据库中来更新该数字。作为练习，我想使用 Combine 来完成它。

当应用程序启动时，我能够显示数据库中的元素数量，但是当新数据进入数据库时​​，数字不会更新（我通过实现一个手动刷新的按钮验证了新数据正在添加用户界面）。

这是在启动时显示正确数量的元素但在添加新记录时不更新的代码：

let replayRecordFetchRequest: NSFetchRequest<ReplayRecord> = ReplayRecord.fetchRequest()

_ = try? persistentContainer.viewContext.fetch(replayRecordFetchRequest).publisher.count().map { String(format: Constants.Strings.playsText, $0) }.assign(to: \.text, on: self.playsLabel)

这是我改编的 WWDC 2019 Session 230 演讲的代码片段，但这根本不起作用（订阅者永远不会被解雇）：

let replayRecordFetchRequest: NSFetchRequest<ReplayRecord> = ReplayRecord.fetchRequest()

if let replayRecords = try? replayRecordFetchRequest.execute() {
    _ = replayRecords.publisher.count().map { String(format: Constants.Strings.playsText, $0) }.assign(to: \.text, on: self.playsLabel)
}

标签： swiftcore-datacombine

解决方案

所以，直到现在我才知道这一点，但并不是所有的出版商都无限地活着。

问题是，这NSFetchRequest.publisher不是一个长期存在的出版商。它只是提供了一种方法来遍历获取请求中的元素序列。结果，订阅者将在元素迭代后取消。在我的例子中，我计算了在取消之前发布的元素，然后将该值分配到 UI 上。

相反，我应该订阅对托管对象上下文的更改并将该管道分配给我的 UI。这是一些示例代码：

extension NotificationCenter.Publisher {
    func context<T>(fetchRequest: NSFetchRequest<T>) -> Publishers.CompactMap<NotificationCenter.Publisher, [T]> {
        return compactMap { notification -> [T]? in
            let context = notification.object as! NSManagedObjectContext
            var results: [T]?
            context.performAndWait {
                results = try? context.fetch(fetchRequest)
            }
            return results
        }
    }
}

let playFetchRequest: NSFetchRequest<ReplayRecord> = ReplayRecord.fetchRequest()
let replayVideoFetchRequest: NSFetchRequest<ReplayVideo> = ReplayVideo.fetchRequest()

let playsPublisher = contextDidSavePublisher.context(fetchRequest: playFetchRequest).map(\.count)
let replayVideoPublisher = contextDidSavePublisher.context(fetchRequest: replayVideoFetchRequest).map(\.count)

playsSubscription = playsPublisher.zip(replayVideoPublisher).map {
    String(format: Constants.Strings.playsText, $0, $1)

}.receive(on: RunLoop.main).assign(to: \.text, on: self.playsLabel)

推荐阅读