Combine中Future函数的Publisher取消处理方法

在RxSwift中，我们可以创建这类响应式函数：

func aFunc() -> Observable<Void> {
    return Observable.create({ emitter in
        let disposable = Observable
            .combineLatest(someObservable,
                           someOtherObservable)
                .subscribe(onNext: { responseA, responseB in
                    // do stuff
                })

                return Disposables.create {
                    disposable.dispose()
                }
            })
        }

在Combine中，尝试用Future实现类似效果：

func aFunc() -> Future<Void, Error> {
    return Future { promise in
        somePublisher
            .combineLatest(someObservable,
                           someOtherObservable)
                .sink{ responseA, responseB in
                    // do stuff
                }
            })
        }

我困惑的是，Future里找不到RxSwift这段代码的等价实现：

return Disposables.create {
    disposable.dispose()
}

想请教：在Future中处理Publisher取消/释放的标准做法是什么？我试过直接用_ = somePublisher...，但Publisher无法保持活跃，根本不会执行。那是不是该在Publisher末尾加.store(in: &cancellables)？但什么时候取消这些cancellables？有没有类似RxSwift那样返回cancellables的方式？我是不是忽略了什么？

核心逻辑差异：Future 与 Observable 的生命周期绑定区别 #

首先要明确：Combine 的 Future 是单次执行型的 Publisher，它的生命周期和自身的订阅强绑定——当订阅被取消时，Future 内部的闭包会被销毁，对应的上游订阅也会自动终止，这和 RxSwift 里 Observable.create 的手动管理逻辑有本质区别。

标准处理方案 #

1. 用局部 AnyCancellable 绑定订阅生命周期
   在 Future 的闭包里，将上游 Publisher 的订阅赋值给局部的 AnyCancellable 变量，利用 Swift 的内存管理特性：当 Future 的订阅被取消，闭包销毁时，这个局部变量会被自动释放，进而触发上游订阅的取消，完全对应 RxSwift 里返回 Disposables.create 的效果。

   调整后的正确代码：

   func aFunc() -> Future<Void, Error> {
       return Future { promise in
           // 持有订阅，保证Publisher活跃
           let cancellable = somePublisher
               .combineLatest(someObservable, someOtherObservable)
               .sink(
                   receiveCompletion: { completion in
                       // 给Future的promise传递结果
                       switch completion {
                       case .finished:
                           promise(.success(()))
                       case .failure(let error):
                           promise(.failure(error))
                       }
                   },
                   receiveValue: { responseA, responseB in
                       // do stuff
                   }
               )
           
           // 无需手动取消：当Future订阅取消，cancellable会随闭包销毁自动释放
       }
   }
   

2. 为什么不推荐用全局 Set<AnyCancellable>？
   如果把订阅存入外部的 Set<AnyCancellable>，会导致上游 Publisher 的生命周期脱离 Future 控制——即使 Future 的订阅已经取消，上游还会持续执行，这不符合你想要的和 RxSwift 等价的“订阅取消即终止上游”逻辑。

3. 解决 Publisher 不活跃的问题
   之前用 _ = somePublisher... 失效，是因为 Combine 的订阅如果没有被 AnyCancellable 持有，会被立即释放销毁。而上面的代码中，局部 cancellable 会在 Future 订阅存续期间保持持有状态，确保 Publisher 正常执行。

补充：手动控制取消的场景 #

如果需要在自定义时机触发取消，可以在 Future 闭包里将 cancellable 与业务逻辑绑定（比如结合 CancellationToken），但绝大多数场景下，上面的自动绑定方式已经完全匹配 RxSwift 原有的 dispose 逻辑。

内容的提问来源于stack exchange，提问作者Joakim Sjöstedt