我有一个网络请求,其结果必须传播给多个订阅者 .
我的API层实现为 Single observables的源,其中每个 Single 代表网络请求的结果 .
Single
但是,我想使用 Connectable Observable 来实际触发事件:
Connectable Observable
当任何观察者触发 .connect() 方法时
.connect()
Single 被调用
Single 的结果通过管道传送到 PublishSubject onNext 方法 .
PublishSubject
onNext
如何使用RxSwift实现此行为?