RxSwift的使用

一、简介

RxSwift的github地址
RxSwift官方文档
RxSwift官方文档中文翻译

• RxSwift是Swift函数响应式编程的一个开源库，由Github的ReactiveX组织开发、维护
• RxSwift的目的是让数据/事件流和异步任务能够更方便的序列化处理，能够使用Swift进行响应式编程
• RxSwift的本质就是观察者模式

二、RxSwif做了什么

• RxSwif把我们程序中每一个操作都看成一个事件
• 比如一个TextField中的文本改变，一个按钮被点击，或者一个网络请
  求结束等，每一个事件源就可以看成一个管道，也就是sequence
• 比如TextField,当我们改变里面的文本的时候，这个TextField就会不
  断的发出事件，从他的这个sequence中不断的流出，我们只需要监听
  这个sequence，每流出一个事件就做相应的处理。
• 同理，Button也是一个sequence，每点击一次就流出一 个事件。

二、cocoapods安装RxSwift

pod 'RxSwift'
pod 'RxCocoa'

image.png

三、简单使用

1.监听按钮点击

• 传统方式

button.addTarget(self, action: #selector(buttonClick), for: .touchUpInside)

@objc func buttonClick() {
   print("按钮点击")
}

• RxSwift方式

button.rx.tap.subscribe { event in
    print("按钮点击")
}

但是这样写会报一个警告，意思是返回的结果未使用

警告.png

我们一般懒加载一个DisposeBag对象，然后在订阅后面使用就可以消除这个警告。

lazy var bag: DisposeBag = DisposeBag()

button.rx.tap.subscribe { event in
  print("按钮点击")
}.disposed(by: bag)

2.监听输入框文字变化

• 传统方式

// 设置代理
tf.delegate = self

// 代理方法
extension PBHomeViewController: UITextFieldDelegate {
    func textFieldDidChangeSelection(_ textField: UITextField) {
        print("文字变化:\(textField.text!)")
    }
}

• RxSwift方式

tf.rx.text.subscribe { event in
  print("输入变化：\(event.element!!)")
}.disposed(by: bag)
// 或者
tf.rx.text.subscribe (onNext: {string in
  print("输入变化：\(string!)")
}).disposed(by: bag)

3.输入框文字绑定到label上

tf.rx.text.bind(to: label.rx.text).disposed(by: bag)

4.监听属性改变

• 传统方式

label.addObserver(self, forKeyPath: "text", options: .new, context: nil)
label.addObserver(self, forKeyPath: "frame", options: .new, context: nil)

override func observeValue(forKeyPath keyPath: String?, of object: Any?, change: [NSKeyValueChangeKey : Any]?, context: UnsafeMutableRawPointer?) {
   print((change?[.newKey])!)
}

• RxSwift方式

label.rx.observe(String.self, "text").subscribe { event in
   print("文本改变：\(event.element!!)")
}.disposed(by: bag)

label.rx.observe(CGRect.self, "frame").subscribe { event in
    print("frame改变：\(event.element!!)")
}.disposed(by: bag)

5.监听滚动偏移

scrollView.rx.contentOffset.subscribe { point in
  print("滚动偏移：\(point.element!)")
}.disposed(by: bag)