RxSwift系列—RxSwift高阶函数

3.1 组合操作符

3.1.1 startWith

在开始从可观察源发出元素之前，发出指定的元素序列

print("*****startWith*****")
Observable.of("1", "2", "3", "4").startWith("A").startWith("B").startWith("C", "a", "b").subscribe(onNext: { print($0) }).disposed(by: disposeBag)
//效果: CabBA1234

3.1.2 merge

将源可观察序列中的元素组合成一个新的可观察序列，并将像每个源可观察序列发出元素一样发出每个元素

print("*****merge*****")
let subject1 = PublishSubject<String>()
let subject2 = PublishSubject<String>()
// merge subject1和subject2
Observable.of(subject1, subject2).merge().subscribe(onNext: { print($0) }).disposed(by: disposeBag)subject1.onNext("P")
subject1.onNext("X")
subject2.onNext("W")
subject2.onNext("X")
subject1.onNext("P")
subject2.onNext("X")
/// MARK: 任何一个响应都会勾起新序列响应

3.1.3 zip

将多个源可观测序列组合成一个新的可观测序列，并将从组合的可观测序列中发射出对应索引处每个源可观测序列的元素

print("*****zip*****")
let stringSubject = PublishSubject<String>()
let intSubject = PublishSubject<Int>()Observable.zip(stringSubject, intSubject) { stringElement, intElement in"\(stringElement) \(intElement)"}.subscribe(onNext: { print($0) }).disposed(by: disposeBag)stringSubject.onNext("P")
stringSubject.onNext("X") // 到这里存储了 P X 但是不会响应除非;另一个响应
intSubject.onNext(1) // 勾出一个
intSubject.onNext(2) // 勾出另一个
stringSubject.onNext("i") // 存一个
intSubject.onNext(3) // 勾出一个
/// MARK: 只有两个序列同时有值的时候才会响应,否则存值

3.1.4 combineLatest

将源可观测序列组合成一个新的观测序列，并将开始发出联合观测序列的每个源的最新元素可观测序列一旦所有排放源序列至少有一个元素，并且当源可观测序列发出的任何一个新元素

print("*****combineLatest*****")
let stringSub = PublishSubject<String>()
let intSub = PublishSubject<Int>()
Observable.combineLatest(stringSub, intSub) { strElement, intElement in"\(strElement) \(intElement)"}.subscribe(onNext: { print($0) }).disposed(by: disposeBag)stringSub.onNext("P") // 存一个 P
stringSub.onNext("X") // 存了一个覆盖 - 和zip不一样
intSub.onNext(1)      // 发现strOB也有X 响应 X 1
intSub.onNext(2)      // 覆盖1 -> 2 发现strOB 有值X 响应 X 2
stringSub.onNext("PXWX") // 覆盖X -> PXWX 发现intOB 有值2 响应 PXWX 2
// combineLatest 比较zip 会覆盖
// 应用非常频繁: 比如账户和密码同时满足->才能登陆. 不关系账户密码怎么变化的只要查看最后有值就可以 loginEnable

3.1.5 switchLatest

将可观察序列发出的元素转换为可观察序列，并从最近的内部可观察序列发出元素

print("*****switchLatest*****")
let switchLatestSub1 = BehaviorSubject(value: "L")
let switchLatestSub2 = BehaviorSubject(value: "1")
let switchLatestSub  = BehaviorSubject(value: switchLatestSub1)// 选择了 switchLatestSub1 就不会监听 switchLatestSub2switchLatestSub.asObservable().switchLatest().subscribe(onNext: { print($0) }).disposed(by: disposeBag)switchLatestSub1.onNext("G")
switchLatestSub1.onNext("_")
switchLatestSub2.onNext("2")
switchLatestSub2.onNext("3") // 2-3都会不会监听,但是默认保存由 2覆盖1 3覆盖2
switchLatestSub.onNext(switchLatestSub2) // 切换到 switchLatestSub2
switchLatestSub1.onNext("*")
switchLatestSub1.onNext("PXWX") // 原理同上面 下面如果再次切换到 switchLatestSub1会打印出 PXWX
switchLatestSub2.onNext("4")

3.2 映射操作符

3.2.1 map

转换闭包应用于可观察序列发出的元素，并返回转换后的元素的新可观察序列。

print("*****map*****")
let ob = Observable.of(1,2,3,4)ob.map { (number) -> Int inreturn number+2}.subscribe{print("\($0)")}.disposed(by: disposeBag)

3.2.2 flatMap and flatMapLatest

将可观测序列发射的元素转换为可观测序列，并将两个可观测序列的发射合并为一个可观测序列。
这也很有用，例如，当你有一个可观察的序列，它本身发出可观察的序列，你想能够对任何一个可观察序列的新发射做出反应(序列中序列:比如网络序列中还有模型序列)
flatMap和flatMapLatest的区别是，flatMapLatest只会从最近的内部可观测序列发射元素

print("*****flatMap*****")
let boy  = PXPlayer(score: 100)
let girl = PXPlayer(score: 90)
let player = BehaviorSubject(value: boy)player.asObservable().flatMap { $0.score.asObservable() } // 本身score就是序列 模型就是序列中的序列.subscribe(onNext: { print($0) }).disposed(by: disposeBag)
boy.score.onNext(60)
player.onNext(girl)
boy.score.onNext(50)
boy.score.onNext(40)//  如果切换到 flatMapLatest 就不会打印
girl.score.onNext(10)
girl.score.onNext(0)

flatMapLatest实际上是map和switchLatest操作符的组合

3.3 过滤条件操作符

3.3.1 filter

仅从满足指定条件的可观察序列中发出那些元素

print("*****filter*****")
Observable.of(1,2,3,4,5,6,7,8,9,0).filter { $0 % 2 == 0 }.subscribe(onNext: { print($0) }).disposed(by: disposeBag)

3.3.2 distinctUntilChanged

抑制可观察序列发出的顺序重复元素

print("*****distinctUntilChanged*****")
Observable.of("1", "2", "2", "2", "3", "3", "4").distinctUntilChanged().subscribe(onNext: { print($0) }).disposed(by: disposeBag)

3.3.3 elementAt

仅在可观察序列发出的所有元素的指定索引处发出元素

print("*****elementAt*****")
Observable.of("P", "X", "W", "X").elementAt(2).subscribe(onNext: { print($0) }).disposed(by: disposeBag)

3.3.4 single

只发出可观察序列发出的第一个元素(或满足条件的第一个元素)。如果可观察序列发出多个元素，将抛出一个错误。

print("*****single*****")
Observable.of("PXWX", "KK").single().subscribe(onNext: { print($0) }).disposed(by: disposeBag)Observable.of("PXWX", "KK").single { $0 == "KK" }.subscribe { print($0) }.disposed(by: disposeBag)

3.3.5 take

只从一个可观察序列的开始发出指定数量的元素。上面signal只有一个序列在实际开发会受到局限这里引出 take 想几个就几个

print("*****take*****")
Observable.of("Tony", "Jiaxiaochao","KK", "PXWX").take(2).subscribe(onNext: { print($0) }).disposed(by: disposeBag)
// MARK: Tony Jiaxiaochao

3.3.6 takeLast

仅从可观察序列的末尾发出指定数量的元素

print("*****takeLast*****")
Observable.of("Tony", "Jiaxiaochao","KK", "PXWX").takeLast(3).subscribe(onNext: { print($0) }).disposed(by: disposeBag)
// MARK: Jiaxiaochao KK PXWX

3.3.7 takeWhile

只要指定条件的值为true，就从可观察序列的开始发出元素

print("*****takeWhile*****")
Observable.of(1, 2, 3, 4, 5, 6).takeWhile { $0 < 3 }.subscribe(onNext: { print($0) }).disposed(by: disposeBag)
// MARK: 1 2

3.3.8 takeUntil

从源可观察序列发出元素，直到参考可观察序列发出元素
这个应用非常频繁：比如我页面销毁了，就不能获取值了(cell重用运用)

print("*****takeUntil*****")
let sourceSequence = PublishSubject<String>()
let referenceSequence = PublishSubject<String>()sourceSequence.takeUntil(referenceSequence).subscribe { print($0) }.disposed(by: disposeBag)sourceSequence.onNext("PXWX")
sourceSequence.onNext("Jiaxiaochao")
sourceSequence.onNext("KK")referenceSequence.onNext("Tony") // 条件一出来,下面就走不了sourceSequence.onNext("Lina")
sourceSequence.onNext("Mike")
sourceSequence.onNext("Jeak")

3.4 集合控制操作符

3.4.1 toArray

将一个可观察序列转换为一个数组，将该数组作为一个新的单元素可观察序列发出，然后终止

print("*****toArray*****")
Observable.range(start: 1, count: 10).toArray().subscribe { print($0) }.disposed(by: disposeBag)

3.4.2 reduce

从一个设置的初始化值开始，然后对一个可观察序列发出的所有元素应用累加器闭包，并以单个元素可观察序列的形式返回聚合结果 - 类似scan

print("*****reduce*****")
Observable.of(10, 100, 1000).reduce(1, accumulator: +) // 1 + 10 + 100 + 1000 = 1111.subscribe(onNext: { print($0) }).disposed(by: disposeBag)

3.4.3 concat

以顺序方式连接来自一个可观察序列的内部可观察序列的元素，在从下一个序列发出元素之前，等待每个序列成功终止

print("*****concat*****")
let subject1 = BehaviorSubject(value: "KK")
let subject2 = BehaviorSubject(value: "1")let subjectsSubject = BehaviorSubject(value: subject1)subjectsSubject.asObservable().concat().subscribe { print($0) }.disposed(by: disposeBag)subject1.onNext("MARK")
subject1.onNext("JiaXiaoChao")subjectsSubject.onNext(subject2)subject2.onNext("打印不出来")
subject2.onNext("2")subject1.onCompleted() // 必须要等subject1 完成了才能订阅到! 用来控制顺序 网络数据的异步
subject2.onNext("3")

3.5 从可观察对象的错误通知中恢复的操作符

3.5.1 catchErrorJustReturn

从错误事件中恢复，方法是返回一个可观察到的序列，该序列发出单个元素，然后终止

print("*****catchErrorJustReturn*****")
let sequenceThatFails = PublishSubject<String>()sequenceThatFails.catchErrorJustReturn("PXWX").subscribe { print($0) }.disposed(by: disposeBag)sequenceThatFails.onNext("Tony")
sequenceThatFails.onNext("KK") // 正常序列发送成功的
//发送失败的序列,一旦订阅到位 返回我们之前设定的错误的预案
sequenceThatFails.onError(self.pxError)

3.5.2 catchError

通过切换到提供的恢复可观察序列，从错误事件中恢复

print("*****catchError*****")
let recoverySequence = PublishSubject<String>()sequenceThatFails.catchError {print("Error:", $0)return recoverySequence  // 获取到了错误序列-我们在中间的闭包操作处理完毕,返回给用户需要的序列(showAlert)}.subscribe { print($0) }.disposed(by: disposeBag)sequenceThatFails.onNext("PXWX")
sequenceThatFails.onNext("KK") // 正常序列发送成功的
sequenceThatFails.onError(pxError) // 发送失败的序列recoverySequence.onNext("Tony")

3.5.3 retry

通过无限地重新订阅可观察序列来恢复重复的错误事件

print("*****retry*****")
var count = 1 // 外界变量控制流程
let sequenceRetryErrors = Observable<String>.create { observer inobserver.onNext("PXWX")observer.onNext("JXC")observer.onNext("KK")if count == 1 { // 流程进来之后就会过度-这里的条件可以作为出口,失败的次数observer.onError(self.lgError)  // 接收到了错误序列,重试序列发生print("错误序列来了")count += 1}observer.onNext("Tony")observer.onNext("Jeak")observer.onNext("WUXU")observer.onCompleted()return Disposables.create()
}sequenceRetryErrors.retry().subscribe(onNext: { print($0) }).disposed(by: disposeBag)

3.6 Rx流程操作符

3.6.1 debug

打印所有订阅、事件和处理。

print("*****debug*****")
var count = 1let sequenceThatErrors = Observable<String>.create { observer inobserver.onNext("PXWX")observer.onNext("JXC")observer.onNext("KK")if count < 5 {observer.onError(self.lgError)print("错误序列来了")count += 1}observer.onNext("Tony")observer.onNext("Jeak")observer.onNext("WUXU")observer.onCompleted()return Disposables.create()
}sequenceThatErrors.retry(3).debug().subscribe(onNext: { print($0) }).disposed(by: disposeBag)
// MARK: 方便调试

3.6.2 RxSwift.Resources.total:

提供所有Rx资源分配的计数，这对于在开发期间检测泄漏非常有用。

print("*****RxSwift.Resources.total*****")
print(RxSwift.Resources.total)

高阶函数的用法还是有点意思的！但RxSwift高阶函数（操作符）非常多，具体可以看如何选择操作符？

RxSwift系列—RxSwift高阶函数相关推荐

RxSwift之常用高阶函数(操作符Operator)的说明和使用
一.组合操作符 ① startWith startWith 方法会在 Observable 序列开始之前插入一些事件元素,即发出事件消息之前,会先发出这些预先插入的事件消息. 如下所示: Observ ...
[译]Effective Kotlin系列之探索高阶函数中inline修饰符(三)
简述: 不知道是否有小伙伴还记得我们之前的Effective Kotlin翻译系列,之前一直忙于赶时髦研究Kotlin 1.3中的新特性.把此系列耽搁了,赶完时髦了还是得踏实探究本质和基础,从今天开始 ...
map 长度_Python实用教程系列——高阶函数Map、Filter、Reduce
点击上方蓝色文字关注我们吧有你想要的精彩作者 | 那个百分十先生出品 | Python知识学堂上次推文我们介绍了python中的<Logging日志模块>的相关知识,这次推文我们将学 ...
深入理解javascript函数进阶系列第一篇——高阶函数
前面的话前面的函数系列中介绍了函数的基础用法.从本文开始,将介绍javascript函数进阶系列,本文将详细介绍高阶函数定义高阶函数(higher-order function)指操作函数的函数 ...
python高阶函数filter_Python进阶系列连载（13）——Python内置高阶函数filter（上）...
前言进阶部分连载继续~ 如果还没看过我的入门连载部分,先看: 当然,小编的免费入门课程已经有咯,看过连载的朋友可以看看视频再快速梳理一遍~ 前文传送门: filter filter是什么意思呢? 我 ...
Kotlin系列四：标准函数、扩展函数、高阶函数、内联函数
目录一标准函数 1.1 作用域函数 1.1.1 let 1.1.2 with 1.1.3 run 1.1.4 apply 1.1.5 also 1.1.6 takeIf 与 takeUnless ...
函数 tostring_Kotlin实战之Fuel的高阶函数
Fuel 是一个用 Kotlin 写的网络库,与 OkHttp 相比较,它的代码结构比较简单,但是它的巧妙之处在于充分利用了 Kotlin 的语言特性,所以代码看上去干净利落. OkHttp 使用了一 ...
c2064 项不会计算为接受0个参数的函数_【JS必知必会】高阶函数详解与实战
本文涵盖前言高级函数概念函数作为参数的高阶函数 map filter reduce sort详解与实战函数作为返回值的高阶函数 isType函数与add求和函数如何自己创建高阶函数前言一 ...
箭头函数的this指向谁_高阶函数
NodeJS 系列文章,本篇是第一篇,首先,预计将后续高频使用逻辑串一遍,依次是高阶函数,promise以及事件机制.本篇主要是高阶函数. call.bind.apply call.apply 都是改 ...

RxSwift系列—RxSwift高阶函数

3.1 组合操作符

3.1.1 startWith

3.1.2 merge

3.1.3 zip

3.1.4 combineLatest

3.1.5 switchLatest

3.2 映射操作符

3.2.1 map

3.2.2 flatMap and flatMapLatest

3.3 过滤条件操作符

3.3.1 filter

3.3.2 distinctUntilChanged

3.3.3 elementAt

3.3.4 single

3.3.5 take

3.3.6 takeLast

3.3.7 takeWhile

3.3.8 takeUntil

3.4 集合控制操作符

3.4.1 toArray

3.4.2 reduce

3.4.3 concat

3.5 从可观察对象的错误通知中恢复的操作符

3.5.1 catchErrorJustReturn

3.5.2 catchError

3.5.3 retry

3.6 Rx流程操作符

3.6.1 debug

3.6.2 RxSwift.Resources.total:

RxSwift系列—RxSwift高阶函数相关推荐

最新文章

热门文章