为什么我的合并管道中从未调用 sink ？

Question

这是我的管道：

URLSession.shared
      .dataTaskPublisher(for: urlRequest)
      .map { $0.data }
      .mapError { ...... }
      .eraseToAnyPublisher()
      .decode(type: MyObject.self, decoder: JSONDecoder())
      .receive(on: RunLoop.main)
      .catch { [weak self] error -> Just<MyObject> in
        guard let self = self else { return Just(emptyPayload) }
        self.hasError = true
        return Just(emptyPayload)
    }
    .sink(
      receiveCompletion: { [weak self] _ in
        print("i'm here")
      },
      receiveValue: { [weak self] value in
        print("value")
      }
    )

为什么从不调用 sink ？

Answer 1

dataTaskPublisher(for: urlRequest)将异步发送值。当程序执行离开您当前的范围时，不再有对您的管道的引用，并且 ARC 在网络请求完成之前销毁您的管道。

您的管道返回一个Cancelable。要么将该 Cancelable 直接分配给实例变量，要么将store(in:)运算符添加到您的管道中。

另外值得一提的是，如果您在 Xcode playground 中使用组合管道，您的管道可能会比您预期的要长，因为 Playground 试图聪明地保留引用，以便使实验更容易。请参阅此答案，了解您可以在操场上运行的异步示例，即使它不适用我提到的任何修复程序。