merge
2018-08-10 本文已影响10人
CN_HarrySun
merge例子:
把两个接口请求是否完成压缩为一个信号再做操作
Observable.merge(viewModel.endAction.elements, viewModel.payAction.elements)
.observeOn(MainScheduler.instance)
.subscribe(onNext: { [weak self] model in
if let bottomButton = self?.payMethodsView?.bottomButton {
bottomButton.isLoading = false
bottomButton.showSuccessLoading { [weak self] in
self?.pushEndViewController(model: model)
}
} else {
self?.pushEndViewController(model: model)
}
})
.disposed(by: disposeBag)