RxSwift文档翻译4-- Transforming Oper
2017-06-01 本文已影响124人
小白猿
前言
Transforming Operators 将观察序列的Next事件元素做转换的操作
Transforming Operators
-
map
使用一个转换闭包将观察序列的元素进行操作,并返回一个由转后后的事件元素构成的新的序列
example("map") {
let disposeBag = DisposeBag()
Observable.of(1, 2, 3)
.map { $0 * $0 }
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
}
// 控制台打印的结果:
--- map example ---
1
4
9
-
flatMap and flatMapLatest
由于对官方的文档实在没有看太懂,所以直接原因谷歌翻译的结果:
将Observable序列发射的元素转换为Observable序列,并将来自两个Observable序列的发射合并为单个可观测序列。 例如,当您具有自己发出可观测序列的Observable序列,并且您希望能够对来自可观测序列的新的排放作出反应时,这也是有用的。 flatMap和flatMapLatest之间的区别是,flatMapLatest只会从最近的内部Observable序列中发出元素
根据参考文章中有这样一段解释
在 Swift 中,我们可以用flatMap过滤掉map之后的nil结果。在 Rx 中,flatMap可以把一个序列转换成一组序列,然后再把这一组序列『拍扁』成一个序列。
等以后对其有了更深入的理解后再对此节进行修改
example("flatMap and flatMapLatest") {
let disposeBag = DisposeBag()
struct Player {
var score: Variable<Int>
}
let 👦🏻 = Player(score: Variable(80))
let 👧🏼 = Player(score: Variable(90))
let player = Variable(👦🏻)
player.asObservable()
.flatMap { $0.score.asObservable() }
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
👦🏻.score.value = 85
player.value = 👧🏼
👦🏻.score.value = 95
👧🏼.score.value = 100
// 控制台打印的结果:
--- flatMap and flatMapLatest example ---
80
85
90
95
100
如果将 flatMap
修改为flatMapLatest
,那么 player.value 设置为👧🏼的时候, 👦🏻.score.value 就不会被相应,类似于switchLatest,只会相应最近的元素,此时打印结果为
// 控制台打印的结果:
--- flatMap and flatMapLatest example ---
80
85
90
100
-
scan
** 设置一个初始种子值,然后在一个累积闭包(scan的参数)中将种子值和观察序列的元素值进行操作,将结果在和序列下一个元素值进行相同的操作,将操作后的值作为序列的新的元素值 **
Observable.of(10, 100, 1000)
.scan(1) { aggregateValue, newValue in
aggregateValue + newValue
}
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
}
// 控制台打印的结果:
--- scan example ---
11
111
1111
scan
后边的值就是种子,aggregateValue
是原始值,newValue
是新值,aggregateValue + newValue
是具体的操作,过程就是 1 + 10,(1+10)+100, ((1+10)+100) + 1000