ios - 在 Combine 中完成后再次订阅管道的最佳实践

Question

我有一个管道正在等待消息并在之后处理它。完成后，我想重新启动管道并再次等待传入的 InitialMessage。这样做的最佳做法是什么？高度赞赏反馈。

        self.incomingInitialMessage()
            .flatMap { self.handleTransmission(for: $0, transmissionProvider: $1) }
            .subscribe(on: self.transmissionQueue)
            .sink(receiveCompletion: { [weak self] completion in
                   ....
                }, receiveValue: { _ in })
            .store(in: &self.disposeBag)

标签： iosswiftcombine