一、观察者简介

观察者 (Observer) 的作用就是监听事件, 然后对这个时间做出响应, 或者说任何响应事件的行为都是观察者. 比如:

(1) 点击按钮弹出提示框, 那么 "弹出提示框" 就是观察者 Observer<Void>

(2) 请求服务器 JSON 数据后, 将数据打印到控制台, 那 "打印数据" 就是观察者 Observer<JSON>

二、创建观察者

• 在 subscribe 方法中创建

创建观察者最直接的方法就是 subscribe 订阅方法后来描述接收到 Event 之后, 如何做出响应, 比如 onNext、 onError、onCompleted 这些闭包作为观察者.

• 在 bind 方法中创建

下面示例创建一个定时发出索引数的 Observable 序列, 并将索引数显示在 label 上

import UIKit
import RxSwift
import RxCocoa
class ViewController: UIViewController {

    @IBOutlet weak var label: UILabel!
    let disposeBag = DisposeBag()
    override func viewDidLoad() {
        super.viewDidLoad()
        
        //创建序列(每隔一秒发出一个索引数)
        let observable = Observable<Int>.interval(1, scheduler: MainScheduler.instance)
        observable
        .map { "当前索引数：\($0 )"}
        .bind { [weak self](text) in
            //收到发出的索引数后显示到label上
            self?.label.text = text
        }
        .disposed(by: disposeBag)
    }
}

• 使用 AnyObserver 创建观察者

AnyObserver 表示任意一种观察者

(1) 配合 subcribe 方法使用

let observer: AnyObserver<String> = AnyObserver { event in
    switch event {
        case .next(let data):
            print(data)
        case .error(let error):
            print(error)
        case .completed:
            print("completed")
    }
}
        
let observable = Observable.of("A","B","C");
observable.subscribe(observer);

//输出结果
A
B
C
completed

(2) 配合 bindTo 使用

配合 Observable 的数据绑定方法 (bindTo) 使用, 第一个案例可以修改为下 :

import UIKit
import RxSwift
import RxCocoa
class ViewController: UIViewController {

    @IBOutlet weak var label: UILabel!
    let disposeBag = DisposeBag()
    override func viewDidLoad() {
        super.viewDidLoad()
        
        let observer: AnyObserver<String> = AnyObserver.init { [weak self](event) in
            switch event {
            case .next(let text):
                self?.label.text = text;
            default:
                break;
            }
        }
        
        let observable = Observable<Int>.interval(1, scheduler: MainScheduler.instance)
        observable.map { "当前索引数: \($0)" }
        .bind(to: observer)
        .disposed(by: disposeBag)
        
    }
}

三、Binder 在 RxCocoa 中的应用

(1) RxCocoa 在对许多 UI 控件进行扩展时, 就利用 Binder 将控件属性变成观察者, 比如 UIControl + Rx.swift 中的 isEnable 属性就是一个 observer :

extension Reactive where Base: UIControl {
    
    /// Bindable sink for `enabled` property.
    public var isEnabled: Binder<Bool> {
        return Binder(self.base) { control, value in
            control.isEnabled = value
        }
    }
}

(2) 因此我们可以将序列直接绑定到它上面 :

class ViewController: UIViewController {

    @IBOutlet weak var label: UILabel!
    @IBOutlet weak var button: UIButton!
    let disposeBag = DisposeBag()
    override func viewDidLoad() {
        super.viewDidLoad()

        // 切换button的可用状态
        let observable = Observable<Int>.interval(1, scheduler: MainScheduler.instance)
        observable.map { $0 % 2 == 0}
        .bind(to: button.rx.isEnabled)
        .disposed(by: disposeBag)
        
    }
}