我有一个网络请求,其结果必须传播给多个订阅者 .

我的API层实现为 Single observables的源,其中每个 Single 代表网络请求的结果 .

但是,我想使用 Connectable Observable 来实际触发事件:

  • 当任何观察者触发 .connect() 方法时

  • Single 被调用

  • Single 的结果通过管道传送到 PublishSubject onNext 方法 .

如何使用RxSwift实现此行为?