Swift Combine Publisher 二次调用无限循环问题求助

核心问题点 #

1. 重复订阅累积：每次调用getfullFunctionHistory()都会给$isNext添加一个新的sink订阅，且所有订阅都存储在全局的disposables集合中不会自动取消。第二次调用后，多个订阅同时监听isNext的变化，触发多次回调，形成循环。
2. Future误用：Future的设计初衷是封装一次性异步任务，但你在Future内部订阅了持续发送事件的@Published属性$isNext，完全违背了Future的使用场景。
3. 共享状态混乱：logs和isNext是单例的成员变量，多次调用函数时状态未正确重置，第二次调用会基于第一次的残留状态触发异常逻辑。

为什么第二次调用会无限循环？ #

第一次调用完成后，isNext的状态保持为true，且第一个sink订阅仍在监听。第二次调用时：

• 新增第二个sink订阅，由于isNext当前是true，两个订阅会立即触发回调。
• 两个订阅同时修改共享的logs：一个订阅可能刚把logs重置为[1,2,3]，另一个订阅就将其截断为[1,2]，随后设置isNext = true再次触发所有订阅，往复循环无法终止。

针对你的需求（每次调用仅执行一次逻辑，打印一次"done"），推荐以下两种修正方案：

方案1：用Future正确封装一次性任务 #

如果你的业务逻辑是一次性异步操作（比如模拟网络请求），直接用Future封装即可，不需要依赖@Published状态：

import Foundation
import Combine

class TestViewModel: ObservableObject {
    static let singleton = TestViewModel()
    private var disposables = Set<AnyCancellable>()

    func getfullFunctionHistory() -> AnyPublisher<[Int], Error> {
        Future<[Int], Error> { promise in
            // 模拟异步处理（比如网络请求、本地数据库查询）
            DispatchQueue.global().async {
                var logs = [1,2,3]
                while logs.count > 1 {
                    logs = logs.dropLast(1)
                }
                print("done")
                promise(.success(logs))
            }
        }
        .receive(on: DispatchQueue.main) // 切换回主线程，方便UI更新
        .eraseToAnyPublisher()
    }
}

方案2：用局部状态+单次Publisher（适合需要分步触发的场景） #

如果需要分步处理逻辑但仍要保证单次执行，可以用局部状态和PassthroughSubject控制流程，避免共享状态污染：

import Foundation
import Combine

class TestViewModel: ObservableObject {
    static let singleton = TestViewModel()
    private var disposables = Set<AnyCancellable>()

    func getfullFunctionHistory() -> AnyPublisher<[Int], Error> {
        let subject = PassthroughSubject<[Int], Error>()
        var logs = [1,2,3]

        func processNextStep() {
            if logs.count == 1 {
                print("done")
                subject.send(logs)
                subject.send(completion: .finished) // 结束Publisher，自动取消订阅
            } else {
                logs = logs.dropLast(1)
                DispatchQueue.main.async {
                    processNextStep()
                }
            }
        }

        processNextStep()
        return subject.eraseToAnyPublisher()
    }
}

关键优化点 #

• 状态隔离：将logs改为函数内的局部变量，每次调用都是独立的状态，避免跨调用的状态污染。
• 避免永久订阅：不再给@Published属性添加持久订阅，而是让订阅和单次任务绑定，任务完成后自动销毁。
• 符合Combine设计意图：用Future封装一次性任务，用Subject控制临时流程，避免滥用@Published作为流程触发器。

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