swift - RxSwift 异步请求设计

Question

我是 RxSwift 新手，试图找出实现以下目标的最简单方法:

• 登录应用后，第一个“getData”请求完成。该数据至关重要，将在微调器后面加载。收到后，数据将保存在核心数据数据库中。当此任务完成(使用完成 block )时，将启动下一个请求，该请求应在后台异步运行，此处的数据也保存在数据库中。如果访问显示后一个数据的 View 并且尚未从数据库接收和获取数据，则应显示旋转器。

型号

let subject = ReplaySubject<[MyObject]>.create(bufferSize: 3)
var observable : Observable<[MyObject]>?

 init() {
        self.observable = subject
 }
 ...

 self?.insertFirstDataToDb(firstData){
   self?.api.getNextData(param,  success: { (data) -> Void in
    self?.insertNextDataToDb(firstData)

  })
  ... 
}

View Controller

override func viewDidLoad() {
        super.viewDidLoad()
        setupUI()
        // show spinner if data is not available yet
        self.myModel?.observable?
            .subscribe(onNext : { (additionalData) in
                self.updateMyTab(additionalData)
               // hide spinner
        })
        .disposed(by: self.disposeBag)
}

我想这可以在不使用 RxSwift 的情况下完成，会有任何性能问题吗？有什么建议如何解决这个问题吗？

Answer 1

要启动和停止微调器，您可以分别使用 do 运算符的 onSubscribed 和 onNext 闭包。

要依次引导多个请求，我建议使用 flatMapLatest 运算符。为了获得良好的设计，您可以为请求开发一个装饰器，该装饰器将在订阅请求时启动微调器。