接上期:【RxSwift 实践系列 2/3】thinking in Rx- Create和Drive的功能,咱们要实如今uitableview中cell上按钮功能。一样,咱们在cell上直接订阅这个按钮,当接受到点击请求的时候,UserDefaults上去git
以下:github
searchFiled.rx.text
.filter{
($0?.lengthOfBytes(using: .utf8))! > 0 //长度大于1
}
.throttle(0.5, scheduler: MainScheduler.instance) //延迟0.5秒再执行
.flatMap{
ListViewModel().searchFromApi(repositoryName:String(describing: $0!))
}
.asDriver(onErrorJustReturn: [])
.drive(resultTableView.rx.items(cellIdentifier: "SearchTableViewCell", cellType: SearchTableViewCell.self)) {
(tableView, element, cell) in
cell.nameLabel.text = element.name
cell.codeLabel.text = element.code
cell.addBtn.rx.tap.subscribe(
onNext: {
var stocks = UserDefaults.standard.array(forKey: "stockSelected") as! [String]
stocks.append(element.code)
UserDefaults.standard.set(stocks, forKey: "stockSelected")
cell.addBtn.setTitle("已关注", for: .normal)
}
).disposed(by: rx.disposeBag)
}
.disposed(by: rx.disposeBag)
复制代码
可是实际操做上发现问题了,当搜索框输入在不断变化的时候,cell也是在不断的刷新的,cell重用的时候,按钮就会被屡次订阅,形成严重的bug。这里就要用到一个方法:prepareForReuseswift
private(set) var disposeBag = DisposeBag()
//SearchTableViewCell中实现
override func prepareForReuse() {
super.prepareForReuse()
disposeBag = DisposeBag()
}
复制代码
在每次重用cell的时候,咱们会释放以前的disposeBag,而后会为cell建立一个新的disposeBag对象,避免屡次订阅.bash
cell.addBtn.rx.tap.subscribe(
onNext: {
var stocks = UserDefaults.standard.array(forKey: "stockSelected") as! [String]
stocks.append(element.code)
UserDefaults.standard.set(stocks, forKey: "stockSelected")
cell.addBtn.setTitle("已关注", for: .normal)
}
).disposed(by: cell.disposeBag)//注意,这里是cell的disposeBag
复制代码
这样咱们就实现了cell上按钮的实现。网络
最后就是首页列表展现了,首页的展现和搜索列表同样,这里就不啰嗦了,这里有个难点是,股票的价格在不刷新tableview的状况下更新,在日常的实现里咱们只能使用刷新单个cell来实现了,来看看rx的实现方式:app
ListViewModel().getFromApi(repositoryName: "").subscribe(
onNext:{ rs in Observable<[ListModel]>
.just(rs)
.bind(to: self.resultTableView.rx.items(cellIdentifier: "ListTableViewCell", cellType: ListTableViewCell.self)) {(_, model:ListModel, cell:ListTableViewCell) in
//定时任务每两秒执行一次
Observable<Int>.interval(2, scheduler: MainScheduler.instance).subscribe { (event) in
ListViewModel().getOne(repositoryName: model.symbol)
.subscribe(
onNext:{ rs in Observable<ListModel>
.just(rs)
.subscribe{
cell.currentLabel.text = String(describing: rs.current)
cell.nameLabel.text = rs.name
cell.codeLabel.text = rs.code
}.disposed(by: self.rx.disposeBag)
}
).disposed(by: self.rx.disposeBag)
}.disposed(by: self.rx.disposeBag)
}.disposed(by: self.rx.disposeBag)
}
).disposed(by: rx.disposeBag)
复制代码
在绑定的cell里面,对整个cell作一个定时任务interval,每秒获取一次网络数据,订阅这个数据来更新cell的元素,从而实现了cell无刷新的更新。能够说代码上只增长了3行就实现了这个功能!ide
这个用rxSwift实现的添加股票代码实时刷新价格的应用到这里就完成了,能够在这里找到实例代码。post
代码里面还有不少缺陷和须要优化的地方: 好比不少的if else能够用rxSwift作的更简洁、许多错误异常等并无处理,网络受权的提示、添加股票代码后首页并无及时更新。你们能够尝试着用rxSwift继续优化代码。优化
三期连接:ui