连接到已完成的发布者时接收器不接收值

Question

我正在努力理解为什么sink底层代码中没有收到任何值。

func somePublisher() -> AnyPublisher<Bool, Never> {
   let subject = PassthroughSubject<Bool, Never>()
   subject.send(true)
   subject.send(completion: .finished)
   return subject.eraseToAnyPublisher()
}

somePublisher()
   .first()
   .sink { _ in
      print("Completed")
   } receiveValue: {
      print("Received \($0)")
   }
   .store(in: &sinks)

输出：

完全的

如果在连接之前完成，下游的发布者似乎不会收到值。是对的吗？如果我的发布商可以同步完成，我该如何解决这个问题？

Answer 1

PassthroughSubject接收一个值并传递它，它不存储该值，因此如果您在值传递后订阅它，您将不会收到它。

您可以使用CurrentValueSubject，它将存储最新值并在有人订阅时重新发送它。

如果你发送的话，所有这些都是没有意义的completion: .finished。已完成的发布者不会向订阅者发送任何值，因为它已完成。

这是你的固定代码：

func somePublisher() -> AnyPublisher<Bool, Never> {
   let subject = CurrentValueSubject<Bool, Never>(true)
   return subject.eraseToAnyPublisher()
}

var bag: Set<AnyCancellable> = []

somePublisher()
   .first()
   .sink { _ in
      print("Completed")
   } receiveValue: {
      print("Received \($0)")
   }
   .store(in: &bag)