课件源码瑞客swift1期day27响应式编程

n响应式编程（ReactiveProgramming，简称RPp也是一种编程范式，于1997年提出，可以简化异步编程，提供更优雅的数据绑定p一般与函数式融合在一起，所以也会叫做：函数响应式编程（FunctionalReactiveProgramming，简称FRP）n比较著名的、 响应式框架pReactiveCocoaü简称RAC，有Objective-C、Swift版本ü官网： pReactiveü简称Rx，有众多编程语言的版本，比如RxJava、RxKotlin、RxJS、RxCpp、RxPHP、RxGo、RxSwift等等ü官网：nRxSwift（ReactiveXforSwift）ReactiveX的Swift版本p源码：p中文文档：nRxSwift 上已经有详细的安 ，这里只演Ccds方式的安装target'target_name'dopod'RxSwift','~>5'pod'RxCocoa','~>5'

②ppodrepoppod

③importimportRxSwiftimportnpRxSwift：Rx标准API的Swift实现，不包括任何iOSpRxCocoa：基于RxSwift，给iOSUI控件扩展了很多Rx nObservable：负责发 nObserver：负责订阅

序列（Event

publicenumEventpublicenumEvent<Element>///Nextelementisproduced.casenext(Element)///Sequenceterminatedwithanerror.caseerror(Swift.Error)///Sequencecompletedsuccessfully.casecompleted}pnext：perror：携带错误信息，表明Observablepcompleted：表明Observablevarobservable=varobservable=Observable<Int>.create{observerinreturnDisposables.create()}//observable=Observable.of(1,2,observable=Observable.from([1,2,observable.subscribeobservable.subscribe(onNext:{print("next",$0)},onError:print("error", pleted:{},onDisposed:{varobservable=varobservable=Observable<Int>.create{observerinreturnDisposables.create()}//observable=Observable.just(1)observable=Observable.of(1)observable=Observable.from([1])observable.subscribe{eventinletletobservable=period:scheduler:observable.map"数值是\($0.bind(to:.disposed(by:letobserver=AnyObserver<Int>.init{eventinswitchevent{case.next(letdata):letobserver=AnyObserver<Int>.init{eventinswitchevent{case.next(letdata):print(data)casepleted:print("completed")case.error(leterror):print("error",error)}})letbinder=Binder<String>(label){label,textinlabel.text=text}Observable.just(1).map{"数值是\($0)"}.subscribe(binder).dispose()Observable.just(1).map{"数值是\($0)"}.bind(to:binder).dispose()extensionextensionReactivewhereBase:UIView{varhidden:Binder<Bool>{Binder<Bool>(base){view,valueinview.isHidden=value}}}letobservable=scheduler:MainScheduler.instance)observable.map{$0%2==0}.bind(to:button.rx.hidden).disposed(by:bag)n在开发中经常要对各种状态进 ppppBlockletletdata=(name:"Jack",age:(name:"Rose",age:data.bind(to:tableView.rx.items(cellIdentifier:"cell")){,cellcell.textLabel?.text= cell.detailTextLabel?.text="\( }.disposed(by: .subscribe(onNext:{ }).disposed(by: buttonbutton.rx.tap.subscribe(onNext}).disposed(by: classDog:NSObject@objcdynamicvarname:}dog.rx.observe(String.self,.subscribe(onNext:{nameinprint("nameis",name??"nil")}).disposed(by:bag)="larry"="wangwang".subscribe(onNext:{notificationin ",}).disposed(by:Observable.justObservable.just(0.8).bind(to:slider.rx.value.map{}.bind(to:textField.rx.text).disposed(by:.subscribe(onNext:{textinprint("textis",text??"nil")}).disposed(by:p它们是RxCocoa.ControlProperty n在不需要再接 //立即取消订阅 订阅observable.subscribe{eventin/当bag销毁（deinit）时，会自动调用Disposable实例的dispo