一、響應式編程
- 1.1、響應式編程(Reactive Programming，簡稱RP)
響應式編程是一種編程范式，于1997年提出，可以簡化異步編程，提供更優(yōu)雅的數據綁定，一般與函數式融合在一起，所以也會叫做:函數響應式編程(Functional Reactive Programming，簡稱FRP) - 1.2、響應式編程比較著名的、成熟的響應式框架
二、RxSwift
2.1、RxSwift(ReactiveX for Swift)，ReactiveX的Swift版本
RxSwift 源碼
RxSwift中文文檔
建議：RxSwift 是一個比較重的框架，用到它可以說整個項目都可離不開它，與 RAC 差不多-
2.2、 RxSwift 在github上已經有詳細的安裝教程，這里只演示CocoaPods方式的安裝
// 第一步 cd 項目 // 第二步 生成Podfile文件 pod init // 第三步，用Xcode打開Podfile文件，導入RxSwift platform :ios, '9.0' target '項目名稱' do use_frameworks! pod 'RxSwift', '~> 5' pod 'RxCocoa', '~> 5' end // 第四步 自動導入RxSwift pod install提示：項目名稱就是
target_name -
2.3、導入 RxSwift
import RxSwift import RxCocoa模塊說明
- RxSwift:Rx標準API的Swift實現(xiàn)，不包括任何iOS相關的內容
- RxCocoa:基于RxSwift，給iOS UI控件擴展了很多Rx特性
-
2.4、RxSwift 的核心角色
Observable:負責發(fā)送事件(Event)
-
Observer:負責訂閱Observable，監(jiān)聽Observable發(fā)送的事件(Event)
public enum Event<Element> { /// Next element is produced. case next(Element) /// Sequence terminated with an error. case error(Swift.Error) /// Sequence completed successfully. case completed } -
Event有3種
- next: 攜帶具體數據
- error: 攜帶錯誤信息，表明Observable終止，不會再發(fā)出事件
- completed: 表明Observable終止，不會再發(fā)出事件
-
2.5、創(chuàng)建、訂閱 Observable 一
let observable = Observable<Int>.create { observer in observer.onNext(1) observer.onCompleted() return Disposables.create() } observable.subscribe { (event) in switch event { case .next(let element): print(element) case .error(let error): print(error) case .completed: print("completed") } }上面的observable創(chuàng)建等價于下面的
- let observable = Observable.just(1) // just后面是一個整體，可以是數組，如：
Observable.just([1,2,3]) - let observable = Observable.of(1)
- let observable = Observable.from([1])
訂閱 observable.subscribe 還可以寫為如下的表達式
observable.subscribe(onNext: { (element) in print(element) }, onError: { (error) in print(error) }, onCompleted: { print("completed") })如果我們只想 subscribe 執(zhí)行一次可以加上
dispose(),也就是subscribe的返回值調用dispose()，如下，那么再次發(fā)送訂閱也不會再去執(zhí)行observable.subscribe { (event) in }.dispose() observable.subscribe(onNext: { (element) in print(element) }, onError: { (error) in print(error) }, onCompleted: { print("completed") }).dispose() - let observable = Observable.just(1) // just后面是一個整體，可以是數組，如：
-
2.6、創(chuàng)建、訂閱 Observable 二
let bag = DisposeBag() let label = UILabel(frame: CGRect(x: 10, y: 100, width: 100, height: 30)) label.backgroundColor = UIColor.white self.view.addSubview(label) let observable = Observable<Int>.timer(.seconds(3),period: .seconds(1),scheduler: MainScheduler.instance) observable.map { "數值是\($0)" }.bind(to: label.rx.text) .disposed(by: bag) -
2.7、創(chuàng)建 observer
let observer = AnyObserver<Int>.init { event in switch event { case .next(let data): print(data) case .completed: print("completed") case .error(let error): print("error", error) } } Observable.just(1).subscribe(observer).dispose() let binder = Binder<String>(label) { label, text in label.text = text } Observable.just(1).map { "數值是\($0)" }.subscribe(binder).dispose() Observable.just(1).map { "數值是\($0)" }.bind(to: binder).dispose() -
2.8、擴展 Binder 屬性
extension Reactive where Base: UIView { var hidden: Binder<Bool> { Binder<Bool>(base) { view, value in view.isHidden = value } } } let observable = Observable<Int>.interval(.seconds(1), scheduler: MainScheduler.instance) observable.map { $0 % 2 == 0 }.bind(to: button.rx.hidden).disposed(by: bag) -
2.9、傳統(tǒng)狀態(tài)的監(jiān)聽，在開發(fā)中經常要對各種狀態(tài)進行監(jiān)聽，傳統(tǒng)的常見監(jiān)聽方案有
- KVO
- Target-Action
- Notification
- Delegate pBlock Callback
傳統(tǒng)方案經常會出現(xiàn)錯綜復雜的依賴關系、耦合性較高，還需要編寫重復的非業(yè)務代碼
-
2.10、RxSwift的狀態(tài)監(jiān)聽一
-
button 事件的監(jiān)聽
button.rx.controlEvent(UIControl.Event.touchUpInside).subscribe(onNext: { (sender) in print("點擊了target,tag=\(sender)") }).disposed(by: bag)提示：如果僅僅是點擊事件我們可以使用
button.rx.tap -
tableview 數據的綁定監(jiān)聽
let data = Observable.just([ Person(name: "Jack", age: 10), Person(name: "Rose", age: 20)]) data.bind(to: tableView.rx.items(cellIdentifier: "cell")) { row, person, cell in cell.textLabel?.text = [person.name](person.name) cell.detailTextLabel?.text = "\(person.age)" }.disposed(by: bag) tableView.rx.modelSelected(Person.self) .subscribe(onNext: { person in print("點擊了", [person.name](person.name)) }).disposed(by: bag) tableView.rx.itemSelected.subscribe(onNext: { path in print("點擊了", path) }).disposed(by: bag)提示：如果cell使我們自定義的，那么 .items(cellIdentifier: "cell"))，后面的type要寫：
.items(cellIdentifier: "cell", cellType: 自定義cell的名字.self))
-
-
2.11、RxSwift的狀態(tài)監(jiān)聽二
class Dog: NSObject { @objc dynamic var name: String? } dog.rx.observe(String.self, "name").subscribe(onNext: { name in print("name is", name ?? "nil") }).disposed(by: bag) [dog.name](dog.name) = "larry" [dog.name](dog.name) = "wangwang" -
2.12、RxSwift的狀態(tài)監(jiān)聽三：通知，下面是進入后臺的通知
NotificationCenter.default.rx.notification(UIApplication.didEnterBackgroundNotification).subscribe(onNext: { notification in print("APP進入后臺", notification) }).disposed(by: bag) -
2.12、既是Observable，又是Observer
[Observable.just(0.8).bind(to](Observable.just(0.8).bind(to): slider.rx.value).dispose()滑塊的value
slider.rx.value.map { "當前數值是:\($0)"}.bind(to: textField.rx.text).disposed(by: bag)textField內容的監(jiān)聽
textField.rx.text.subscribe(onNext: { text in print("text is", text ?? "nil") }).disposed(by: bag)諸如UISlider.rx.value、UTextField.rx.text這類屬性值，既是Observable，又是Observer ，它們是
RxCocoa.ControlProperty類型 -
2.13、Disposable
- 每當Observable被訂閱時，都會返回一個Disposable實例，當調用Disposable的dispose，就相當于取消訂閱
- 在不需要再接收事件時，建議取消訂閱，釋放資源。有3種常見方式取消訂閱
-
立即取消訂閱(一次性訂閱)
observable.subscribe { event in print(event) }.dispose() -
當bag銷毀(deinit)時，會自動調用Disposable實例的dispose
observable.subscribe { event in print(event) }.disposed(by: bag) -
self銷毀時(deinit)時，會自動調用Disposable實例的dispose
let _ = observable.takeUntil(self.rx.deallocated).subscribe { event in print(event) }
-
最后：航歌里面有更多的RxSwift的用法，大家可以學習
