观察者（Observer）的作用就是监听事件，然后对这个事件做出响应。或者说任何响应事件的行为都是观察者
比如：
- 当我们点击按钮，弹出一个提示框。那么这个“弹出一个提示框”就是观察者 Observer
- 当我们请求一个远程的 json 数据后，将其打印出来。那么这个“打印 json 数据”就是观察者 Observer
1，在 subscribe 方法中创建
- 创建观察者最直接的方法就是在 Observable 的 subscribe 方法后面描述当事件发生时，需要如何做出响应。
- 比如下面的样例，观察者就是由后面的 onNext，onError，onCompleted 这些闭包构建出来的。
let observable = Observable<Int>.interval(1, scheduler: MainScheduler.instance)
observable.subscribe(onNext: { [weak self] element in
let text = "当前索引\(element)"
self?.label.text = text
}, onError: { error in
print(error)
}, onCompleted: {
print("completed")
}).disposed(by: disposeBag)
2，在 bind 方法中创建
下面代码我们创建一个定时生成索引数的 Observable 序列，并将索引数不断显示在 label 标签上：
//Observable序列（每隔1秒钟发出一个索引数）
let observable = Observable<Int>.interval(1, scheduler: MainScheduler.instance)
observable
.map { "当前索引数：\($0)"}
.bind { [weak self](text) in
self?.label.text = text
}
.disposed(by: disposeBag)
3、 AnyObserver 创建观察者
AnyObserver 可以用来描叙任意一种观察者。
基础方法
//观察者
let observer:AnyObserver<Int> = AnyObserver {[weak self] (event) in
switch event{
case .next(let text):
self?.label.text = "当前索引数：\(text)"
case .error(let error):
print(error)
case .completed:
print("completed")
}
}
//序列
let observable = Observable<Int>.interval(1, scheduler: MainScheduler.instance)
observable.subscribe(observer).disposed(by: disposeBag)
配合 bindTo 方法使用
//观察者
let observer:AnyObserver<String> = AnyObserver { [weak self](event) in
switch event {
case .next(let text):
//收到发出的索引数后显示到label上
self?.label.text = text
default:
break
}
}
//Observable序列（每隔1秒钟发出一个索引数）
let observable = Observable<Int>.interval(1, scheduler: MainScheduler.instance)
observable
.map { "当前索引数：\($0 )"}
.bind(to: observer)
.disposed(by: disposeBag)
4、使用 Binder 创建观察者
（1）相较于 AnyObserver 的大而全，Binder 更专注于特定的场景。Binder 主要有以下两个特征：
- 不会处理错误事件
- 确保绑定都是在给定 Scheduler 上执行（默认 MainScheduler）
（2）一旦产生错误事件，在调试环境下将执行 fatalError，在发布环境下将打印错误信息。
//观察者
let observer:Binder<String> = Binder(label){ (view, text) in
//收到发出的索引数后显示到label上
view.text = text
}
//Observable序列（每隔1秒钟发出一个索引数）
let observable = Observable<Int>.interval(1, scheduler: MainScheduler.instance)
observable
.map { "当前索引数：\($0 )"}
.bind(to: observer)
.disposed(by: disposeBag)
其实 RxCocoa 在对许多 UI 控件进行扩展时，就利用 Binder 将控件属性变成观查者，比如 UIControl+Rx.swift 中的 isHidden 属性便是一个 observer ： 因此我们可以将序列直接绑定到它上面
let observable = Observable<Int>.interval(1, scheduler: MainScheduler.instance)
observable
.map { $0 % 2 == 0 }
.bind(to: self.label.rx.isHidden)
.disposed(by: disposeBag)