如何使用Swift与Combine发布函数结果并实现指定终止逻辑？

要实现反复调用guessANumber()并发布结果，直到输出为0时终止序列，可以通过Combine的自定义发布者或操作符组合来完成，以下是两种常见实现方式：

方式一：同步生成序列（直接循环调用） #

这种方式会在当前线程同步执行，一次性生成所有结果直到出现0：

import Combine

func guessANumber() -> Int { Int.random(in: 0...9) }

// 创建自定义发布者
let numberPublisher = Publishers.Create<Int, Never> { subscriber in
    var keepGenerating = true
    while keepGenerating {
        let number = guessANumber()
        // 发送当前生成的数字
        subscriber.receive(number)
        // 遇到0时发送完成事件，终止序列
        if number == 0 {
            subscriber.receive(completion: .finished)
            keepGenerating = false
        }
    }
    // 返回空的取消器（同步场景无需清理）
    return AnyCancellable {}
}

// 订阅发布者
let cancellable = numberPublisher
    .sink(
        receiveCompletion: { _ in print("序列已终止") },
        receiveValue: { print("收到数字: \($0)") }
    )

方式二：异步定时生成序列 #

如果需要每隔一段时间生成一个数字（避免阻塞主线程），可以结合DispatchQueue或Timer实现：

基于DispatchQueue的异步实现 #

let asyncNumberPublisher = Publishers.Create<Int, Never> { subscriber in
    let backgroundQueue = DispatchQueue.global(qos: .background)
    let workItem = DispatchWorkItem {
        var keepGenerating = true
        while keepGenerating {
            let number = guessANumber()
            subscriber.receive(number)
            if number == 0 {
                subscriber.receive(completion: .finished)
                keepGenerating = false
            }
            // 每隔0.5秒生成一次，避免过快输出
            Thread.sleep(forTimeInterval: 0.5)
        }
    }
    backgroundQueue.async(execute: workItem)
    
    // 取消订阅时终止后台任务
    return AnyCancellable {
        workItem.cancel()
    }
}

let asyncCancellable = asyncNumberPublisher
    .receive(on: DispatchQueue.main) // 切换到主线程更新UI（可选）
    .sink(
        receiveCompletion: { _ in print("异步序列已终止") },
        receiveValue: { print("异步收到数字: \($0)") }
    )

基于Timer的实现（定时触发） #

let timerBasedPublisher = Timer.publish(every: 0.5, on: .main, in: .common)
    .autoconnect()
    .map { _ in guessANumber() }
    .handleEvents(receiveOutput: { number in
        if number == 0 {
            // 手动取消定时器
            timerCancellable?.cancel()
        }
    })
    .eraseToAnyPublisher()

var timerCancellable: AnyCancellable?
timerCancellable = timerBasedPublisher
    .sink(
        receiveCompletion: { _ in print("定时器序列已终止") },
        receiveValue: { print("定时器收到数字: \($0)") }
    )

关键逻辑说明 #

• 自定义发布者（Publishers.Create）：最灵活的实现方式，能完全控制序列的生成、发送和终止时机，适配同步或自定义异步场景。
• 终止条件处理：当生成的数字为0时，必须调用subscriber.receive(completion: .finished)通知订阅者序列结束，此时订阅会自动取消。
• 资源清理：异步场景下，返回的AnyCancellable用于在取消订阅时终止后台任务，避免资源泄漏。

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