Swift Publisher为何始终不触发？排查Combine与Core Data集成问题

核心问题：误用reduce操作符 #

你的代码里用reduce([])处理CollectionDifference是错误的。reduce是终止型操作符，它会收集上游所有输出，直到上游发送.finished完成事件后，才会把最终累计结果传给下游。但ManagedObjectChangesPublisher是持续监听Core Data数据变化的Publisher，永远不会主动发送完成事件，因此reduce会一直阻塞，永远不会向下游传递任何值——这就是后续compactMap和sink都不触发的根本原因。

修复方案：用scan替代reduce #

scan是持续型累计操作符，每次上游发送新值时，它会立即把当前累计的结果传给下游，完全匹配你的场景：

修改TaskService的monitor()方法：

func monitor() -> AnyPublisher<[Task], Error> {
    return monitorPublisher
        .scan([]) { (accum: [TaskEntity], diff: CollectionDifference<TaskEntity>) -> [TaskEntity] in
            return accum.applying(diff) ?? []
        }
        .compactMap { $0.compactMap(Task.init(entity:)) }
        .eraseToAnyPublisher()
}

额外优化与验证点 #

1. 初始数据加载：确认ManagedObjectChangesPublisher在订阅时会发送初始数据集对应的变更（或初始数组）。如果它只在数据变更时发送，需手动添加初始数据发布逻辑，比如在scan前先发送一次空数组，或者让Publisher在订阅时返回当前所有数据。
2. 线程安全：Core Data的viewContext操作默认在主线程，而你在UIViewController中订阅，建议在sink前添加.receive(on: DispatchQueue.main)确保UI线程安全：

taskService.monitor()
    .receive(on: DispatchQueue.main)
    .sink(receiveCompletion: { _ in }) { tasks in
        print(tasks)
    }.store(in: &cancellables)

3. 避免崩溃风险：你的Task.init(entity:)用了fatalError()，若Core Data实体存在缺失值会直接崩溃，建议改为返回nil，由compactMap过滤无效数据：

init?(entity: TaskEntity) {
    guard let id = entity.id,
          let creationDate = entity.creationDate,
          let title = entity.title else { return nil }
    
    self.id = id
    self.creationDate = creationDate
    self.title = title
}

测试验证 #

修改后可在viewDidLoad中添加测试任务，验证Publisher是否正常触发：

override func viewDidLoad() {
    super.viewDidLoad()
    
    view.backgroundColor = .white
    
    // 创建测试任务
    let taskEntity = TaskEntity(context: taskService.coreDataStack.container.viewContext)
    taskEntity.id = UUID()
    taskEntity.title = "Test Task"
    taskEntity.creationDate = Date()
    try? taskService.coreDataStack.container.viewContext.save()
    
    taskService.monitor()
        .receive(on: DispatchQueue.main)
        .sink(receiveCompletion: { completion in
            print("Completion: \(completion)")
        }) { tasks in
            print("Received tasks: \(tasks)")
        }.store(in: &cancellables)
}

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