推荐书本：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")
})
}
========================================
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)
}
========================================
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)
}
========================================
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)
}
}
