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

Question

这个问题在这里已经有了答案:





URLSession.shared.dataTaskPublisher not working on IOS 13.3

(3 个回答)


1年前关闭。




这是我的管道:

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 在网络请求完成之前销毁您的管道。

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

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