如何让Swift Combine Publisher运行指定时长后自动停止

核心实现思路 #

• 绝大多数响应式编程框架（Combine、Rx系列、Project Reactor等）都原生提供了timeout操作符，专门用于处理流的超时终止场景
• 你只需要把timeout操作符插入到Publisher调用链中、绑定sink的位置之前，设置10秒的超时阈值即可
• 超时触发后，操作符会自动向下游发送完成/错误事件，同时向上游的WiFi扫描Publisher发送取消信号，自动终止扫描动作

常见框架代码示例 #

Combine（iOS/macOS 生态） #

// 你的原有WiFi扫描Publisher
wifiScanPublisher
    // 配置10秒超时，超时后直接发送完成事件，不抛出错误
    .timeout(.seconds(10), scheduler: DispatchQueue.main) {
        Empty<WiFiScanResult, Never>(completeImmediately: true)
    }
    // 原有sink逻辑不需要修改
    .sink(
        receiveCompletion: { completion in
            // 正常扫描结束、10秒超时都会触发该回调
        },
        receiveValue: { result in
            // 处理扫描到的WiFi列表数据
        }
    )
    .store(in: &cancellables)

RxJava/RxKotlin（安卓生态） #

wifiScanPublisher
    // 10秒超时后直接发送完成事件
    .timeout(10, TimeUnit.SECONDS, Observable.empty())
    .subscribe(
        { result -> /* 处理WiFi扫描结果 */ },
        { error -> /* 仅处理扫描本身的错误，超时不会触发该回调 */ },
        { /* 扫描结束/超时触发完成回调 */ }
    )

注意事项 #

• 需要确保你的WiFi扫描Publisher正确实现了取消回调：收到上游（这里是timeout操作符）发来的取消信号时，能主动调用系统API停止WiFi扫描，避免后台无效扫描耗电
• 如果你需要区分「正常扫描结束」和「超时终止」两种状态，可以自定义一个超时专属错误类型，在超时后抛出该错误，在sink的错误/完成回调中做区分处理即可

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