RxSwift 初探

RxSwift 简介

• ReactiveX（简写: Rx） 是一个函数式响应式编程的基础框架,可以帮助我们简化编程。
• RxSwift 是 Rx 的 Swift 版本。

---

函数式响应式编程(FRP)

• 函数式编程是种编程方式，它将电脑运算视为函数的计算。函数编程语言最重要的基础是λ演算（lambda calculus），而且λ演算的函数可以接受函数当作输入（参数）和输出（返回值）。
  和指令式编程相比，函数式编程强调函数的计算比指令的执行重要。
  和过程化编程相比，函数式编程里函数的计算可随时调用。
• 响应式编程是一种面向数据流和变化传播的编程范式。这意味着可以在编程语言中很方便地表达静态或动态的数据流，而相关的计算模型会自动将变化的值通过数据流进行传播。

---

为什么要用RxSwift

• 复合 - Rx 就是和复合的代名词
• 复用 - 复⽤性⽐较强 - 代码量降低
• 清晰 - 因为声明都是不可变更，代码函数式编程可读性强
• 易用 - 理解容易，还抽象的了异步编程，统一代码⻛格
• 稳定 - 因为 Rx 是完全通过单元测试的
• 装逼 - 代码的逼格很明显⽐原生高太多了

---

可观察序列(Observable)

可观察序列(Observable) ,序列中主要有三种类型的数据(信号), Next,Error,Complete.如下图:

Observable

• Next 是 Observable 用来交付正常数据(信号).
• Error 可以交付错误信号,就是去通知 Observer,哪里出了问题
• Complete 可以通知 Observer 已经完成,没有可以提交的数据了

• 示例代码

let url = URL.init(string: "http://www.baidu.com")!
let urlRequest = URLRequest.init(url: url)
URLSession.shared.rx.response(request: urlRequest)
    .subscribe(onNext: { (response,data) in
        
        print("接收响应数据\(data)")
    }, onError: { (error) in
        
        print("错误\(error)")
    }, onCompleted: {
        
        print("完成")
    })

---

Observable 核⼼流程

主要分为三步:

• Create: 创建可观察的序列
• Subscribe: 添加订阅
• on: 发送信号,Next,Error,Complete.

Observable 核⼼流程

• 示例代码

// 1. 创建一个序列
let ob = Observable<Any>.create{ (ob) -> Disposable in
    
    // 3. 发送信号
    ob.onNext("zhongxiaoyue")
    ob.onCompleted()
    
    return Disposables.create()
}

// 2.给这个序列 添加一个订阅者
let _ = ob.subscribe(onNext: { (text) in
    
    print("接收到信号:\(text)")
}, onError: { (error) in
    
    print("发生错误error: \(error)")
}, onCompleted: {
    
    print("完成")
}) {
    
    print("销毁")
}

---

RxSwift 应用示例

• 网络请求

func setupNextwork() {
    
    let url = URL(string: "https://www.baidu.com")
    URLSession.shared.rx.response(request: URLRequest(url: url!))
    .subscribe(onNext: { (response,data) in
        print(response)
    }).disposed(by: disposeBag)
    
}

• timer定时器

func setupTimer() {

    timer = Observable<Int>.interval(1, scheduler: MainScheduler.instance)
    timer.subscribe(onNext: { (num) in
        print(num)
    })
    .disposed(by: disposeBag)
}

• 通知

func setupNotification(){
    NotificationCenter.default.rx.notification(UIResponder.keyboardWillShowNotification)
        .subscribe(onNext: { (noti) in
            print(noti)
        })
        .disposed(by: disposeBag)
    
}

• 手势

func setupGestureRecognizer(){
    
    let tap = UITapGestureRecognizer()
    self.label.addGestureRecognizer(tap)
    self.label.isUserInteractionEnabled = true
    tap.rx.event
        .subscribe(onNext: { (tap) in
            print(tap.view)
        })
        .disposed(by: disposeBag)
}

• scrollView

func setupScrollerView() {

    scrollView.rx.contentOffset
        .subscribe(onNext: { [weak self](content) in
            self?.view.backgroundColor = UIColor.init(red: content.y/255*0.8, green: content.y/255*0.6, blue: content.y/255*0.3, alpha: 1)
        })
        .disposed(by: disposeBag)
}

• textfiled

func setupTextFiled() {
    
    self.textFiled.rx.text.orEmpty
        .subscribe(onNext: { (text) in
           print(text)
        })
        .disposed(by: disposeBag)
}

• button响应

func setupButton() {

    self.button.rx.tap
        .subscribe(onNext: { () in
            print("点击了")
        })
        .disposed(by: disposeBag)
}

• KVO

func setupKVO() {
    
    self.person.rx.observeWeakly(String.self, "name")
        .subscribe(onNext: { (value) in
            print(value as Any)
        })
        .disposed(by: disposeBag)
}