Swift 结合发布者与完成处理程序以及何时取消

Question

我知道发布者通常比闭包更强大，但是我想询问并讨论一个具体的例子：

func getNotificationSettingsPublisher() -> AnyPublisher<UNNotificationSettings, Never> {
   let notificationSettingsFuture = Future<UNNotificationSettings, Never> { (promise) in
      UNUserNotificationCenter.current().getNotificationSettings { (settings) in
         promise(.success(settings))
      }
   }
   return notificationSettingsFuture.eraseToAnyPublisher()
}

我认为这是 Future 发布者的一个有效示例，可以在这里使用它而不是使用完成处理程序。让我们用它做点什么：

func test() {
    getNotificationSettingsPublisher().sink { (notificationSettings) in
       // Do something here        
    }
}

这有效，但是它会告诉我 sink ( AnyCancellable)的结果未使用。因此，每当我尝试获取一个值时，我都需要存储可取消对象或分配它，直到我获得一个值。

是否有类似 sinkOnce 或可取消项的自动销毁之类的东西？有时我不需要取消的任务。但是我可以这样做：

func test() {
   self.cancellable = getNotificationSettingsPublisher().sink { [weak self] (notificationSettings) in
      self?.cancellable?.cancel()
      self?.cancellable = nil
   }
}

所以一旦我收到一个值，我就会取消订阅。（我猜我可以在水槽的完成关闭中做同样的事情）。

这样做的正确方法是什么？因为如果我使用一个闭包，它会被调用多少次函数被调用，如果它只被调用一次，那么我不需要取消任何东西。

你会说普通的完成处理程序可以用组合代替吗？如果是这样，你会如何处理接收一个值然后取消？

最后但并非最不重要的是，调用完成，我还需要取消订阅吗？我至少需要更新可取消并将其设置为 nil 对吗？我假设将订阅存储在一个集合中是为了长期运行的订阅，但是单值订阅呢？

谢谢

Answer 1

.sink您可以Sink直接使用订阅者，而不是使用运营商。这样您就不会收到AnyCancellable需要保存的文件。当发布者完成订阅时，Combine 会清理所有内容。

func test() {
    getNotificationSettingsPublisher()
        .subscribe(Subscribers.Sink(
            receiveCompletion: { _ in },
            receiveValue: ({
                print("value: \($0)")
            })
        ))
}