1

我有一个Subject可观察的表示需要传递给多个订阅者的网络请求的结果。

我可以使用ReplaySubject缓冲区 1 和publish()方法。但是，网络请求只执行一次。

我想在将来的任何给定点触发 fetch 事件。如何触发新请求？

目前，我有一个Service包含 的对象，ReplaySubject并且有一个reload()触发网络请求并将结果发布到 a 的方法ReplaySubject。

是否有任何方法Observable可以“刷新”它并向所有当前订阅者提供新价值？

4

1 回答 1

3

如果我正确地解释了这个问题，这是 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()发生后更新。

于 2018-05-01T05:52:43.257 回答