一、订阅
创建了 Observable 序列, 还需要用 subscribe() 方法来订阅它,以接收该序列发出的 Event .
- 订阅方法一
(1) 使用 subcribe() 订阅 Observable 对象, 用 block 来接收 Event 事件
//创建
let observable = Observable.of("A","B");
//订阅
observable.subscribe { event in
print(event);
}
//输出结果
next(A)
next(B)
completed
(2) 使用 event.element 来获取事件中的数据
//创建
let observable = Observable.of("A","B");
//订阅
observable.subscribe { event in
print(event.element);//输出数据
}
//输出结果
Optional("A")
Optional("B")
nil
- 订阅方法二
(1) RxSwift 还提供另一个 subscribe 方法, 可以将 Event 进行分类, 通过不同的 闭包 回调处理不同类型的 Event, 同时会把 Event 携带的数据直接解包出来作为参数
//创建
let observable = Observable.of("A","B","C");
//订阅
observable.subscribe(onNext: { (element) in
print(element)
}, onError: { (error) in
print(error)
}, onCompleted: {
print("completed")
},onDisposed: {
print("disposed") // onDisposed 表示订阅行为被 dispose 后的回调
})
//输出结果
A
B
C
completed
disposed
(2) subscribe() 方法的 onNext、onError、 onCompleted 和 onDisposed 这四个回调都是有默认值的,所以这些方法不是必须的,可以选择执行某个方法.
//创建
let observable = Observable.of("A","B","C");
//订阅
observable.subscribe(onNext: { (element) in
print(element)
})
//输出结果
A
B
C
二、监听事件的声明周期
- doOn
(1) 使用 doOn 来监听事件的声明周期, 会在每次事件发送之前被调用
(2) 和 subscribe 事件一样, 可以通过不同的闭包回调来区分 Event 事件类型, 比如 : do(onNext:) 方法在 subscribe(onNext:) 之前调用.
let observable = Observable.of("A","B","C")
observable.do(onNext: { (element) in
print("-- \(element)")
}, onError: { (error) in
print("-- error")
}, onCompleted: {
print("-- completed")
}, onSubscribe: {
print("-- subscribe1")
}, onSubscribed: {
print("-- subscribe2")
}, onDispose: {
print("-- disposed")
})
.subscribe(onNext: { (element) in
print(element)
}, onError: { (error) in
print(error)
}, onCompleted: {
print("completed")
}, onDisposed: {
print("disposed")
})
//输出结果
-- subscribe1
-- subscribe2
-- A
A
-- B
B
-- C
C
-- completed
completed
disposed
-- disposed
Observable 销毁(Dispose)
- Observable 从创建到销毁流程
(1) 一个 Observable 序列被创建出来后,不会马上被激活发送 Event, 而是等到它被订阅后才会被激活.
(2) Observable 激活之后, 一直等到它发出 .error 或者 .completed 之后, 才会被销毁
- dispose()
(1) 使用该方法可以手动取消一个订阅行为
(2) 如果一个订阅行为被 dispose 了, Observable 序列再发出 Event, 订阅者不会受到消息
- DisposeBag
除了 dispose() 方法之外, 还可以使用 DisposeBag 对象来管理多个订阅的销毁行为, 我们可以把 DisposeBag 看做一个容器, 将所有订阅行为存放到容器中, DisposeBag 在 dealloc 的时候,会对其中存储的所有订阅行为执行 dispose() 方法进行销毁.
let disposeBag = DisposeBag()
let observable1 = Observable.of("A","B");
observable1.subscribe { (event) in
print(event)
}.disposed(by: disposeBag)
let observable2 = Observable.of("A","B");
observable2.subscribe { (event) in
print(event)
}.disposed(by: disposeBag)
