可被监听的序列.
- Observable
简单粗暴的理解序列 :
举个简单的例子，当别人在跟你说话时，你就是那个观察者，别人就是那个 Observable，它有几个特点：
* 可能会不断地跟你说话。（onNext:）
* 可能会说错话。（onError:）
* 结束会说话。（onCompleted）
你在听到对方说的话后，也可以有几种反应：
* 根据说的话，做相应的事，比如对方让你借本书给他。（subscribe）
* 把对方说的话，加工下再传达给其他人，比如对方说小张好像不太舒服，你传达给其他人时就变成了小张失恋了。（map:）
* 参考其他人说的话再做处理，比如 A 说某家店很好吃，B 说某家店一般般，你需要结合两个人的意见再做定夺。（zip:）
- 序列(Observable) : 从开始聊天,到结束聊天的这一个过程
- 观察者(Observer) : 倾听的人
Observable序列的创建
创建序列 : Observable.create
生产序列元素 : observer.onNext(2)
结束生产序列元素 : observer.onCompleted()
let numbers: Observable<Int> = Observable.create { observer -> Disposable in
observer.onNext(2)
observer.onNext(1)
observer.onNext(0)
observer.onNext(1)
observer.onNext(2)
observer.onNext(3)
observer.onNext(4)
observer.onNext(5)
observer.onCompleted()
return Disposables.create()
}
numbers.subscribe(onNext: { (i) in
print(i)
if i == 2 {
print("2")
} else if i == 6 {
print("6") //这里因为没有6的这个元素,所以不会打印
}
}, onError: { (error) in
print(error)
}, onCompleted: {
print("complete")
}) {
print("Disposables.create")
}
---------------------------------
注意 : 元素值可以相等,打印结果顺序和创建序列顺序一致
打印结果 :
2
2
1
0
1
2
2
3
4
5
complete
Disposables.create
---------------------------------
关注内容
关注内容一 :
observer.onNext(2) //元素
...... //元素
observer.onNext(5) //元素
关注内容二 :
.subscribe(onNext: { (i) in //i为对应的序列元素内容
处理事件
}
都是对应的序列内容,简单粗暴理解就是当你倾听别人在聊到什么话题的时候,将要做什么样的反应.
PS: 首先关注的点应该是序列有什么内容,还有怎么创建.暂时不考虑具体使用. 不然会有点懵
简单使用(注意上面所说的2个关注内容)
typealias JSON = Any
class ViewController: UIViewController {
let viewModel = ViewModel()
var model : MoyaModel?
let json: Observable<JSON> = Observable.create { (observer) -> Disposable in
let task = URLSession.shared.dataTask(with: URL.init(string: "www.baidu.com")!, completionHandler: { (data, reponse, error) in
guard error == nil else {
observer.onError(error!)
return
}
guard let data = data,
let jsonObject = try? JSONSerialization.jsonObject(with: data, options: .mutableLeaves)
else {
return
}
observer.onNext(jsonObject) //生产序列元素
observer.onCompleted() //结束生产序列元素
})
task.resume()
return Disposables.create { task.cancel() }
}
override func viewDidLoad() {
super.viewDidLoad()
json.subscribe(onNext: { (json) in
print("json = \(json)")
}, onError: { (error) in
print("error = \(error)")
}, onCompleted: {
print("complete")
}) {
print("dis")
}
}
}
打印结果
2018-07-18 15:16:13.164056+0800 RxSwiftDemo[6169:272021] Task <B7C3A022-B977-4D08-A92D-8C199B0343DA>.<1> finished with error - code: -1002
error = Error Domain=NSURLErrorDomain Code=-1002 "unsupported URL" UserInfo={NSUnderlyingError=0x60c00004c750 {Error Domain=kCFErrorDomainCFNetwork Code=-1002 "(null)"}, NSErrorFailingURLStringKey=www.baidu.com, NSErrorFailingURLKey=www.baidu.com, NSLocalizedDescription=unsupported URL}
dis
PS : 参考Observable - 可被监听的序列学习,看到这里其实疑惑的点还有很多.这里只是简单的给出了一个使用例子.感觉也很抽象.
整体理解总结
let json: Observable<JSON> = Observable.create { (observer) -> Disposable in ... }
拆解为大白话(非专业,只为简单理解)
let json: 聊天过程<倾听的内容类型> = 聊天过程.创造 { (倾听的人) -> 对话结束 in
聊天过程中的反应处理.....
}
参考博文 :
【领略RxSwift源码】- 订阅的工作流（Subscribing）
【领略RxSwift源码】- 变换操作（Operators）
【领略RxSwift源码】- 主题类族（Subject）
