在 Swift 的 Combine 发布器中包装异步代码答案

【问题标题】：Wrapping asynchronous code in Swift's Combine publisher在 Swift 的 Combine 发布器中包装异步代码
【发布时间】：2020-04-23 02:00:06
【问题描述】：

我有一个名为QueryObserver 的类，它可以随着时间的推移产生多个结果，作为回调（闭包）返回。你可以这样使用它：

let observer = QueryObserver<ModelType>(query: query) { result in
  switch result {
  case .success(let value):
    print("result: \(value)")
  case .failure(let error):
    print("error: \(error)")
  }
}

（如果您想知道的话，QueryObserver 实际上是 Firebase Firestore 笨拙的 query.addSnapshotListener 功能的封装。使用现代 Result 类型而不是带有多个可选参数的回调。）

在一个较旧的项目中，我正在使用 ReactiveKit 并有一个扩展，可以将所有这些变成 Signal，如下所示：

extension QueryObserver {
  public static func asSignal(query: Query) -> Signal<[T], Error> {
    return Signal { observer in
      let queryObserver = QueryObserver<T>(query: query) { result in
        switch result {
        case .success(let value):
          observer.receive(value)
        case .failure(let error):
          if let firestoreError = error as? FirestoreError, case .noSnapshot = firestoreError {
            observer.receive([])
          } else {
            observer.receive(completion: .failure(error))
          }
        }
      }

      return BlockDisposable {
        queryObserver.stopListening()
      }
    }
  }
}

不过，在一个全新的项目中，我正在使用 Combine 并试图重写它。到目前为止，我已经设法写了这个，但它不起作用。这是有道理的：observer 不会被任何东西保留，因此它会立即被释放，并且没有任何反应。

extension QueryObserver {
  public static func asSignal(query: Query) -> AnyPublisher<[T], Error> {
    let signal = PassthroughSubject<[T], Error>()

    let observer = QueryObserver<T>(query: query) { result in
      switch result {
      case .success(let value):
        print("SUCCESS!")
        signal.send(value)
      case .failure(let error):
        if let firestoreError = error as? FirestoreError, case .noSnapshot = firestoreError {
          signal.send([])
        } else {
          signal.send(completion: .failure(error))
        }
      }
    }

    return signal.eraseToAnyPublisher()
  }
}

如何使组合版本工作？如何包装现有的异步代码？我发现的唯一示例使用 Future 进行一次性回调，但随着时间的推移，我正在处理多个值。

基本上我正在寻找this 的 ReactiveKit-to-Combine 版本。

【问题讨论】：

你必须将你的发布者保存在一些存储属性中（比如私有成员）以及任何订阅者（比如here）。

标签： swift combine reactivekit

【解决方案1】：

查看https://github.com/DeclarativeHub/ReactiveKit/issues/251#issuecomment-575907641 以获得一个方便的组合版本的信号，使用如下：

let signal = Signal<Int, TestError> { subscriber in
    subscriber.receive(1)
    subscriber.receive(2)
    subscriber.receive(completion: .finished)
    return Combine.AnyCancellable {
        print("Cancelled")
    }
}

【讨论】：