我有一个 Subject
observable 表示需要传递给多个订阅者的网络请求的结果。
我可以使用缓冲区 1 的 ReplaySubject
和 publish()
方法。但是,网络请求只执行一次。
我想在将来的任何给定时间点触发获取事件。如何触发新请求?
目前,我有一个 Service
对象,它包含 ReplaySubject
并且有一个方法 reload()
触发网络请求并发布结果到 aReplaySubject
。
Observable
是否有任何方法可以“刷新”它并向所有当前订阅者传递新值?
最佳答案
如果我正确地解释了这个问题,那么这是 RxSwift 中一个相当普遍的问题。每次“触发”抓取时,您都需要能够重新创建网络请求 Observable
,但您需要在仅创建一次的单个 Observable
上交付这些结果,并且有多个订阅者。这是通过 flatMap
完成的:
struct Service {
var resultsObservable: Observable<Results> {
return resultsSubject.asObservable()
}
private let resultsSubject: ReplaySubject<Results> = .create(bufferSize: 1)
private let reloadSubject = PublishSubject<Void>()
private let disposeBag = DisposeBag()
init() {
bindFetch()
}
func reload() {
reloadSubject.onNext(())
}
private func bindFetch() {
reloadSubject
.asObservable()
.flatMap(fetch)
.bind(to: resultsSubject)
.disposed(by: disposeBag)
}
private func fetch() -> Observable<Results> {
// URLSession just one example
let urlRequest = URLRequest(url: URL(string: "https://apple.com")!)
return URLSession
.shared
.rx
.data(request: urlRequest)
.map(Results.init)
.catchErrorJustReturn(Results.empty())
}
}
在此示例中,您可以多次订阅 resultsObservable
,并且每次都应在新的 reload()
发生后更新。
关于ios - RxSwift 触发可观察执行,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/50043435/