推荐书本：RxSwift
电子版地址：https://pan.baidu.com/s/1bp8MlC7 密码 5tjx
本文是RxSwift书本 学习笔记
书本code地址：https://pan.baidu.com/s/1o7GVBrO

安装RxSwift和RxCocoa

    pod 'RxSwift', '~> 3.3.1'
    pod 'RxCocoa', '~> 3.3.1'

学习时可在项目中创建playground进行。

截图

创建方法

public func example(of description: String,action: ()->Void){
    print("======Example of : \(description)")
    action()
}

========================================
Observable和Observer

Observable相当于KVO里的被观察对象，也是事件源。而Observer就是我们的观察者，也就是当收到事件的时候去做某些处理。观察者需要去订阅(subscribe)被观察者，才能收到Observable的事件通知消息。

========================================

just是创建一个sequence只能发出一种特定的事件，能正常结束（最后返回 completed ）

例：

Observable<Int>.just(one)

Add this code to the bottom of the example:

example(of: "just, of , from"){
    let one = 1
    let two = 2
    let three = 3
    let observable: Observable<Int> =   
    Observable<Int>.just(one) //创建被观察对象

//创建订阅
    observable.subscribe{event in
        print(event)
    }
}

打印结果

打印结果

========================================
观察者为每个元素发出一个.next 事件，然后发出一个.next 的事件，最后终止。
当使用观测值时，您通常会对下一事件发出的元素更感兴趣，而不是与事件本身相关。
要查看如何访问这些代码，请用下面的代码替换上面

observable.subscribe { event in
  if let element = event.element {
    print(element)
  }
}

或

observable.subscribe(onNext: { element in
    print(element)
})

打印结果

empty就是创建一个空的sequence,只能发出一个completed事件
当你想返回一个可立即终止的或有意为零的可见值时。

example(of: "empty") {
  let observable = Observable<Void>.empty()
}

打印结果

========================================
never就是创建一个sequence，但是不发出任何事件信号。
与.empty相反，从.never符创建一个可见的，不释放任何东西，从不终止。它可以用来表示无限长时间。

example(of: "never") {
    let observable = Observable<Any>.never()
    observable.subscribe(onNext: { element in
        print(element)
    }, onCompleted: {
        print("Completed")
    })
}

没有打印Completed

========================================

range就是创建一个sequence，他会发出这个范围中的从开始到结束的所有事件

example(of: "range") { 
    let observable = Observable<Int>.range(start: 1, count: 10)
    observable.subscribe(onNext: { i in
        let n = Double(i)
        let fibonacci = Int(((pow(1.61803, n) - pow(0.61803, n)) /
            2.23606).rounded())
        print(fibonacci)
    }, onCompleted: { 
        print("Completed")
    })
}

打印如下

========================================

DisposeBag
DisposeBag其实就相当于iOS中的ARC，会在适当的时候销毁观察者，相当于内存管理者吧。
使用adddisposableto()方法

example(of: "DisposeBag") {
  // 1
  let disposeBag = DisposeBag()
// 2
  Observable.of("A", "B", "C")
    .subscribe { // 3
print($0) }
    .addDisposableTo(disposeBag) // 4
}
}

create
我们也可以自定义可观察的sequence，那就是使用create

example(of: "create") { 
    let disposeBag = DisposeBag()
    Observable<String>.create{ observer in
        observer.onNext("1")
        observer.onCompleted()
        observer.onNext("?")
        return Disposables.create()
    }.subscribe(onNext: {print($0)}, onError: {print($0)}, onCompleted: {print("Completed")}, onDisposed: {print("Disposed")}).addDisposableTo(disposeBag)
}

这里没有打印 ？因为在之前就已经Completed了

========================================

onError 发出错误然后终止

example(of: "create") {
    enum MyError: Error{
        case anError
    }
    let disposeBag = DisposeBag()
    Observable<String>.create{ observer in
        observer.onError(MyError.anError)
        observer.onNext("1")
        
        observer.onCompleted()
        observer.onNext("?")
        return Disposables.create()
    }.subscribe(onNext: {print($0)}, onError: {print($0)}, onCompleted: {print("Completed")}, onDisposed: {print("Disposed")}).addDisposableTo(disposeBag)
}

1、? 和 Completed 不打印

========================================

deferred
deferred 会等到有订阅者的时候再通过工厂方法创建 Observable 对象，每个订阅者订阅的对象都是内容相同而完全独立的序列。

example(of: "deferred") { 
    let disposeBag = DisposeBag()
    
    var flip = false
    let factory: Observable<Int> = Observable.deferred({
        flip = !flip
        if flip{
            return Observable.of(1,2,3)
        }else{
            return Observable.of(4,5,6)
        }
    })
    
    for _ in 0...3{
        factory.subscribe(onNext: {print($0)}).addDisposableTo(disposeBag)
    }
}