【RxSwift 实践系列 2/3】thinking in Rx- Create和Drive

---> 上节 【RxSwift 实践系列 1/3】为何使用RxSwift

RxSwift 是一种编程思想，不是一门语言，学习他最难的部分就是thinking in Reactive Programming ：把全部事件看成一个 stream来思考。 它的目的是让数据/事件流和异步任务可以更方便的序列化处理

若是把咱们程序中每个操做都当作一个事件: 好比一个TextFiled中的文本改变，一个按钮的点击，或者一个网络请求结束等，每个事件源就能够当作一个管道，也就是Sequence，好比一个TextFiled，当咱们改变里边的文本的时候 这个时候TextFiled就会不断的发出事件， 从他的Sequence中不断的流出 咱们只须要监听这个Sequence，每流出一个事件就作相应的处理。同理UIButton也是一个Sequence 每点击一次就流出一个事件

---

接下来咱们一步步的用thinking in Reactive Programming思想来实现一个实时展现股票信息的app.

app需求：

一、准备工做：

二、网络请求准备

三、功能：输入股票帐号，显示相关股票

四、添加到关注列表，从网络获取股票信息

五、实时显示关注列表的股票数据状况
复制代码

一、 准备工做

咱们须要建立一个stock的项目，并使用Podfile管理第三方库。 关于RxSwift的基本使用方法能够在github的RxSwift查看。

Podfile的配置以下：

platform :ios, '11.0'
use_frameworks!
target 'stock' do
    pod 'RxSwift','~> 4.0'
    pod 'RxCocoa','~> 4.0' #把UI库和rx结合
    pod 'FMDB', '~>2.6.2'  #sqlite数据库
    pod 'SwiftyJSON'  #json处理
    pod 'Moya/RxSwift'  #网络请求
    pod 'ObjectMapper', '~> 3.1' #Json转模型
    pod 'MJRefresh', :inhibit_warnings => true #下拉刷新
    pod 'RxDataSources', '~> 3.0'  #帮助咱们优雅的使用tableView的数据源方法
    pod 'NSObject+Rx'     #为咱们提供 rx_disposeBag
    pod 'Then'            #提供快速初始化的语法糖
    pod 'Reusable'        #帮助咱们优雅的使用自定义cell和view,再也不出现Optional
end
 
 #rx的debug使用
 post_install do |installer|
     installer.pods_project.targets.each do |target|
         if target.name == 'RxSwift'
             target.build_configurations.each do |config|
                 if config.name == 'Debug'
                     config.build_settings['OTHER_SWIFT_FLAGS'] ||= ['-D', 'TRACE_RESOURCES']
                 end
             end
         end
     end
 end


复制代码

二、 网络请求

经过网络请求，处理返回数据
    
知识点：Observable  create   subscribe   disposed  moya
复制代码

thinking in Reactive Programming

网络请求是一个经典的异步请求，moya是基于Alamofire实现的一个网络请求，它的网络请求也是一个可订阅的stream，咱们在此基础上建立一个可订阅的模型，把网络返回结果发送给这个模型，提供给订阅者展出到uitableview中

/** 这里咱们使用moya来作网络请求，moya的具体使用方法参见[Moya](https://github.com/Moya/Moya) 咱们把moya从网络api返回的结果当作一个stream，使用rxswift的create把返回结果变成一个可订阅的信息流 */
    //create的方法能够参见手册：
    create(_ subscribe: @escaping (RxSwift.AnyObserver<Self.E>) -> Disposable)
    //主要步骤是：
    Observable.create { observer in
        observer.onNext(10)
        observer.onCompleted()
        return  Disposables.create()
    }
        
    //接下来咱们实现这个从api获取股票信息的方法，建立了一个可订阅的数据模型
    let netToolProvider = MoyaProvider<StockApi>()
    func searchFromApi(repositoryName: String) -> Observable<[SearchModel]> {
        return Observable.create { observer in
            netToolProvider.rx.request(.SearchStocks(code:repositoryName))
                .mapJSON() //Moya RxSwift的扩展方法，能够把返回的数据解析成 JSON 格式
                .subscribe( //订阅返回的结果
                    onSuccess:{json in
                        let info = self.parseSearchResponse(response: json as AnyObject) // 把返回解析成一个listmodel对象
                        observer.on(.next(info)) //发送next 内容是listmodel
                        observer.on(.completed)  //发送成功
                },
                    onError:{error in
                        observer.on(.error(error)) //发送错误
                }).disposed(by: self.bag)//自动内存处理机制
            
            return  Disposables.create()
        }
    }
    
    private func parseSearchResponse(response: AnyObject) -> [SearchModel] {
        var info: [SearchModel] = []
        let items = response["stocks"] as! [[String:AnyObject]]
        let _ = items.filter{
                return $0["stock_id"] as! Int != 0 //把退市的去掉
            }.map{
                info.append(SearchModel(JSON: $0)!)
            }
        return info;
    }
    
复制代码

咱们先把这个方法留着，等会咱们会订阅这个模型，展现到uitableview中去

三、响应输入框将结果展现到列表

用户输入股票编号，调用接口去显示搜索结果
    
知识点：RxCocoa ，bind, drive
复制代码

thinking in Reactive Programming：

把输入框事件当作一个流，用户的输入就会不断的发出事件流，咱们只须要监听事件流就能够响应用户的每次输入。

searchFiled.rx.text
    .filter{
        ($0?.lengthOfBytes(using: .utf8))! > 0 //输入长度大于1才处理数据
    }
    .throttle(0.5, scheduler: MainScheduler.instance) //延迟0.5秒再执行
    .subscribe{ //订阅这个事件
        print($0) //打印用户的输入
}.disposed(by: rx.disposeBag)
复制代码

获取用户的输入后，还须要即时的根据用户输入去api获取搜索结果，对于搜索结果咱们已经在刚才处理了。如今要作的是用户输入和api搜索的事件绑定在一块儿。这里rxswift提供了bind方法。

bind,这个方法意图就是将一个被观察者与一个指定的观察者进行绑定，被观察者事件流中发出的全部事件元素都会让观察者接收。
例如：
textField.rx_text
    .bindTo(label.rx_text)
    .addDisposableTo(disposeBag)
复制代码

接下来咱们来处理事件流发出者（searchFiled）和观察者（resultTableView）绑定在一块儿，当用户输入查询字符串，即时去接口获取查询结果，展现在uitableview中：

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!)) //查询结果，返回可订阅的SearchModel
    }
    //事件流发出者（searchFiled）和观察者（resultTableView）绑定在一块儿
    .bind(to: self.resultTableView.rx.items(cellIdentifier: "SearchTableViewCell", cellType: SearchTableViewCell.self)) {(_, model:SearchModel, cell:SearchTableViewCell) in
        cell.nameLabel.text = model.name
        cell.codeLabel.text = model.code
    }
.disposed(by: rx.disposeBag)

复制代码

可是若是用bind，会有几个问题： 1.若是searchFromApi错误（链接失败，参数错误等），错误将会丢失（得不到任何处理），UI也不会再处理和响应任何的结果

2.若是searchFromApi返回的结果不是在主线程，那么不在子线程中对UI进行绑定，就会出现未知的错误

3.若是返回的结果绑定到了两个UI上，那么意味着每个UI都要进行一次网络请求，即进行两次网络请求，那么，咱们能够稍稍修改一下

咱们能够这样修改一下：

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!))//查询结果，返回可订阅的SearchModel
                .observeOn(MainScheduler.instance) // 将返回结果切换到到主线程上
                .catchErrorJustReturn([])  // 若是有问题，错误结果将会获得处理
        }
        .share(replay: 1)
        //事件流发出者（searchFiled）和观察者（resultTableView）绑定在一块儿
        .bind(to: self.resultTableView.rx.items(cellIdentifier: "SearchTableViewCell", cellType: SearchTableViewCell.self)) {(_, model:SearchModel, cell:SearchTableViewCell) in
            cell.nameLabel.text = model.name
            cell.codeLabel.text = model.code
        }
    .disposed(by: rx.disposeBag)

复制代码

这里插一句：subscribeOn和observeOn的区别： subscribeOn()设置起点在哪一个线程，observeOn()是设置的后续工做在哪一个线程。

这里咱们设计的仍是不够完美，rxswift中提供了drive方法，但是说是专为UI绑定量身打造

drive方法只能在Driver序列中使用，Driver有如下特色：

1. Driver序列不容许发出error，

2. Driver序列的监听只会在主线程中。
复制代码

让咱们来看看drive的实现方法：

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
    }
    .disposed(by: rx.disposeBag)

复制代码

因此如下状况你可使用Driver替换BindTo: 

一、不能发出error;

二、在主线程中监听;

三、共享事件流;
复制代码

本节先到这里，详细代码能够到这里：rxStock实例 下载参考

下一节将介绍rxcocoa的使用场景，以及实现这个股票app所用到的更多rxswift方法。

【RxSwift 实践系列 3/3】thinking in Rx- UITableView

上一节回顾 【RxSwift 实践系列 1/3】为何使用RxSwift