目录:
RxSwift - 入门
RxSwift Observable Create
RxSwift Subject
RxSwift Combination Operators
RxSwift Transforming Operators
RxSwift Filterning and conditional operators
RxSwift Mathematical and aggregate operators
RxSwift Connectable Operators
RxSwift ErrorHandding Operators
RxSwift Debug Operators
Demo地址
RxSwift Transforming Operators
上一节了解了一下Combination Operators,现在我们进行看看还有哪些常用的Operators
map
通过一个transform closure 把elements进行一次形变，返回一个新的事件序列（Observable sequence）
example("map") {
let bag = DisposeBag()
Observable.of(1, 2, 3)
.map { $0 * $0 }
.subscribe(onNext: { print($0) })
.disposed(by: bag)
}
// 1 4 9
map
flatMap
会把序列中的每一个事件，变成一个新的Observable，也就是说在flatMap的transform closure中要返回一个Observable。
example("flatMap and flatMapLatest") {
let bag = 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() }
//.flatMapLatest { $0.score.asObservable() }
.subscribe(onNext: { print($0) })
.disposed(by: bag)
👦🏻.score.value = 85
player.value = 👧🏼
// 如果之前使用了flatMapLatest进行形变，那么这个值讲不会打印
👦🏻.score.value = 95
👧🏼.score.value = 100
}
flatMap
scan
会需要输入一个初始值，然后在closure中进行修改，用于下一次事件使用
example("scan") {
let bag = DisposeBag()
Observable.of(10, 100, 1000)
.scan(1) { aggregateValue, newValue in
aggregateValue + newValue
}
.subscribe(onNext: { print($0) })
.disposed(by: bag)
// 11 111 1111
Observable.of("10", "100", "1000")
.scan("1") { aggregateValue, newValue in
aggregateValue + newValue
}
.subscribe(onNext: { print($0) })
.disposed(by: bag)
// "110" "110100" "1101001000"
}
scan
buffer
需要我们传入三个参数，分别是:
-
timeSpan: 时间间隔 -
count： 最大缓存数量 -
scheduler： 在哪里进行调度
所以buffer的意思就是允许我们把事件统一起来处理，其中不管是timeSpan还是count，只要有一种满足条件了，就会把事件从指定的调度发送出来。
example("buffer") {
let bag = DisposeBag()
let subject = PublishSubject<String>()
subject.asObserver()
.buffer(timeSpan: 2, count: 5, scheduler:
MainScheduler.instance)
.subscribe(onNext: { print($0) })
.disposed(by: bag)
subject.onNext("1")
subject.onNext("2")
subject.onNext("3")
subject.onNext("4")
subject.onNext("5")
subject.onNext("6")
subject.onNext("7")
dispatchMain()
}
// ["1", "2", "3", "4", "5"]
// ["6", "7"]
buffer.png
可以看到，只要时间间隔后者达到最大缓存数中的两个条件，满足其中任意一个，都会把事件发送给订阅者
window
和buffer类似，但是他返回但是一个Observable list
example("window") {
let bag = DisposeBag()
let subject = PublishSubject<String>()
subject.asObserver()
.debug()
.window(timeSpan: 2, count: 5, scheduler: MainScheduler.instance)
.flatMap { ob -> Observable<String> in
print(ob)
return ob.asObservable()
}
.subscribe(
onNext: { print($0) }
).disposed(by: bag)
subject.onNext("a")
subject.onNext("b")
subject.onNext("c")
subject.onNext("d")
subject.onNext("e")
subject.onNext("f")
subject.onNext("g")
subject.onNext("h")
DispatchQueue.global()
.asyncAfter(
deadline: DispatchTime.now() + 0.5,
execute: {
subject.onNext("i")
})
DispatchQueue.global()
.asyncAfter(
deadline: DispatchTime.now() + 4,
execute: {
subject.onNext("j")
subject.onNext("k")
subject.onNext("l")
})
dispatchMain()
}
运行结果如下：
---------- window ----------
RxSwift.AddRef<Swift.String>
2018-09-22 14:39:58.589: TransformOperators.swift:97 (init()) -> subscribed
2018-09-22 14:39:58.591: TransformOperators.swift:97 (init()) -> Event next(a)
a
2018-09-22 14:39:58.591: TransformOperators.swift:97 (init()) -> Event next(b)
b
2018-09-22 14:39:58.591: TransformOperators.swift:97 (init()) -> Event next(c)
c
2018-09-22 14:39:58.591: TransformOperators.swift:97 (init()) -> Event next(d)
d
2018-09-22 14:39:58.591: TransformOperators.swift:97 (init()) -> Event next(e)
e
RxSwift.AddRef<Swift.String>
2018-09-22 14:39:58.592: TransformOperators.swift:97 (init()) -> Event next(f)
f
2018-09-22 14:39:58.592: TransformOperators.swift:97 (init()) -> Event next(g)
g
2018-09-22 14:39:58.592: TransformOperators.swift:97 (init()) -> Event next(h)
h
2018-09-22 14:39:59.137: TransformOperators.swift:97 (init()) -> Event next(i)
i
RxSwift.AddRef<Swift.String>
RxSwift.AddRef<Swift.String>
2018-09-22 14:40:02.594: TransformOperators.swift:97 (init()) -> Event next(j)
j
2018-09-22 14:40:02.594: TransformOperators.swift:97 (init()) -> Event next(k)
k
2018-09-22 14:40:02.595: TransformOperators.swift:97 (init()) -> Event next(l)
l
结论：只有满足过时间间隔或者最大缓存数之后才会开启一个新的Observable List。
这个和buffer类似了，偷个懒把官方的图拿过来
Window
skipUntil
和
takeUntil类似，表示一直忽略，知道参数中的Observable发送了onNext事件
example("skipUntil") {
let disposeBag = DisposeBag()
let sourceSequence = PublishSubject<String>()
let referenceSequence = PublishSubject<String>()
sourceSequence
.skipUntil(referenceSequence)
.subscribe(onNext: { print($0) })
.disposed(by: disposeBag)
sourceSequence.onNext("1")
sourceSequence.onNext("2")
sourceSequence.onNext("2")
referenceSequence.onNext("3")
sourceSequence.onNext("1")
sourceSequence.onNext("4")
sourceSequence.onNext("2")
}
[图片上传失败...(image-d6b738-1540968691551)]
throttle
当发送很多事件时，每隔多少ms取一次事件值
使用场景：滑动Slider的时候回产生很多值，当我们并不想处理每次的值，只想在值的变化过程中取一些值
progressSlider.rx
.value.asObservable()
.throttle(0.4, scheduler: MainScheduler.instance)
.map(progress)
.bind(to: progressLabel.rx.text)
.disposed(by: bag)
debounce
当上一次的值和下一次的值超出时间间隔之后，就把事件的值发送出来
使用场景：避免用户多次点击按钮导致多次请求等类似情况
button.rx
.tap.asObservable()
.debounce(0.3, scheduler:MainScheduler.instance)
.map(btnTapCount)
.bind(to: btnLabel.rx.text)
.disposed(by: bag)
filter.gif
