变换操作符
变换操作符是指对原始的 Observable 序列进行一些变换.
1. buffer
(1) 简介
-
buffer方法的作用是缓冲组合, 第一个参数是缓冲时间, 第二个参数是缓冲个数, 第三个是参数是线程 -
buffer的作用就是缓存Observable中发出的元素, 当元素达到某个数量, 或者经过指定时间, 它就会将这个元素集合发送出来.
buffer.png
(2) 案例
let disposeBag = DisposeBag()
let subject = PublishSubject<String>()
//每缓存三个元素,则组合起来一起发出
//如果一秒钟内不够三个也会发出(有几个发几个, 一个没有就发送空数组)
subject.buffer(timeSpan: 1, count: 3, scheduler: MainScheduler.instance)
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
subject.onNext("a")
subject.onNext("b")
subject.onNext("c")
subject.onNext("11")
subject.onNext("22")
subject.onNext("33")
//输出结果
["a", "b", "c"]
["11", "22", "33"]
2. window
(1) 简介
-
window操作符和buffer十分相似.buffer是周期性的将缓存的元素集合发送出来, 而window是周期性的将元素集合以Observable的形态发送出来 -
buffer要等元素搜集完毕后,才会发出元素序列. 而window可以实时发出元素序列.
window.png
(2) 案例
let disposeBag = DisposeBag()
let subject = PublishSubject<String>()
subject.window(timeSpan: 1, count: 3, scheduler: MainScheduler.instance)
.subscribe(onNext: { [weak self] in
print("subscribe: \($0)")
$0.asObservable()
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
})
.disposed(by: disposeBag)
subject.onNext("a")
subject.onNext("b")
subject.onNext("c")
subject.onNext("1")
subject.onNext("2")
subject.onNext("3")
//输出结果
subscribe: RxSwift.AddRef<Swift.String>
a
b
c
subscribe: RxSwift.AddRef<Swift.String>
1
2
3
subscribe: RxSwift.AddRef<Swift.String>
subscribe: RxSwift.AddRef<Swift.String>
...
3. map
(1) 简介
- 该操作符通过传入一个函数闭包把原来的
Observable序列转变成一个新的Observable序列
map.png
(2) 案例
let disposeBag = DisposeBag()
Observable.of(1,2,3)
.map {$0 * 10}
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
//输出结果
10
20
30
4. flatMap
(1) 简介
-
flatMap操作符会对源Observable的每一个元素应用一个转换方法, 将他们转换成Observables, 然后将这些Observables的元素合并之后再发出来
flatMap.png
(2) 案例
let disposeBag = DisposeBag()
let first = BehaviorSubject(value: "1")
let second = BehaviorSubject(value: "A")
let be = Variable(first)
be.asObservable()
.flatMap { $0 }
.subscribe(onNext: { print($0) }) //订阅发送上一个event,即默认值
.disposed(by: disposeBag)
first.onNext("2") //发出event 2
be.value = second //订阅second
second.onNext("B") //发出event B
first.onNext("3") //发出event 3
//输出结果
1
2
A
B
3
5. flatMapLatest
(1) 简介
-
flatMapLatest与flatMap的唯一区别是:flatMapLatest只会接收最新的value事件
flatMapLatest.png
(2) 案例
let disposeBag = DisposeBag()
let first = BehaviorSubject(value: "1")
let second = BehaviorSubject(value: "A")
let be = Variable(first)
be.asObservable()
.flatMapLatest { $0 }
.subscribe(onNext: { print($0) }) //订阅发送上一个event,即默认值
.disposed(by: disposeBag)
first.onNext("2") //发出event 2
be.value = second //订阅second
second.onNext("B") //发出event B
first.onNext("3") //现在value为 second , 所以不会发出event
//输出结果
1
2
A
B
6. flatMapFirst
(1) 简介
-
flatMapFirst与flatMapLatest正好相反,flatMapFirst只会接收最初的value事件
(2) 案例
let disposeBag = DisposeBag()
let first = BehaviorSubject(value: "1")
let second = BehaviorSubject(value: "A")
let be = Variable(first)
be.asObservable()
.flatMapFirst { $0 }
.subscribe(onNext: { print($0) }) //订阅发送上一个event,即默认值
.disposed(by: disposeBag)
first.onNext("2") //发出event 2
be.value = second //订阅second
second.onNext("B") //只会发出最初value的event
first.onNext("3") //发出3
//输出结果
1
2
3
7. concatMap
(1) 简介
-
concatMap与flatMap的唯一区别是: 当前一个Observable元素发送完毕后, 后一个Observable才可以开始发出元素, 或者说等待前一个Observable产生完成事件后, 才对后一个Observable进行订阅
concatMap.png
(2) 案例
let disposeBag = DisposeBag()
let first = BehaviorSubject(value: "1")
let second = BehaviorSubject(value: "A")
let be = Variable(first)
be.asObservable()
.concatMap { $0 }
.subscribe(onNext: { print($0) }) //订阅发送上一个event,即默认值
.disposed(by: disposeBag)
first.onNext("2") //发出event 2
be.value = second //first未完结,只做订阅,不发出event
second.onNext("B") //first未完结,等待处理
first.onNext("3") //现在value为 second , 所以不会发出event
first.onCompleted(); //first完结,处理发出的event
//输出结果
1
2
3
B
8. scan
(1) 简介
-
scan就是先给一个初始化的数, 然后不断拿前一个结果和最新的值进行处理操作 -
scan操作符将对第一个元素应用一个函数，将结果作为第一个元素发出。然后，将结果作为参数填入到第二个元素的应用函数中，创建第二个元素。以此类推，直到遍历完全部的元素。
(2) 案例
let disposeBag = DisposeBag()
Observable.of(1,2,3,4)
.scan(0) { (a, b) -> Int in
return a + b
}.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
//输出结果
1
3
6
10
9. groupBy
(1) 简介
-
groupBy操作符将源Observable分解为多个子Observable, 然后将这些子Observable发送出来. 即 该操作符会根据某个条件对源Observable序列进行分组, 在讲分组后的元素以Observable的形态发送出来
groupBy.png
(2) 案例
let disposeBag = DisposeBag()
Observable<Int>.of(0,1,2,3,4,5)
.groupBy { (element) -> String in
return element % 2 == 0 ? "偶数" : "奇数"
}
.subscribe { event in
switch event {
case .next(let group):
group.asObservable().subscribe { (event) in
print("key: \(group.key) event: \(event)" )
}
.disposed(by: disposeBag)
default:
print("")
}
}
.disposed(by: disposeBag)
//输出结果
key: 偶数 event: next(0)
key: 奇数 event: next(1)
key: 偶数 event: next(2)
key: 奇数 event: next(3)
key: 偶数 event: next(4)
key: 奇数 event: next(5)
key: 奇数 event: completed
key: 偶数 event: completed
