RxSwift（5）— 高阶函数（下）

时间  2019-11-07
标签 rxswift 高阶 函数 繁體版
原文   原文链接

就问此时此刻还有谁？45度仰望天空，该死！我这无处安放的魅力！swift

RxSwift 目录直通车 --- 和谐学习，不急不躁！缓存

这一篇文章继续上一篇：RxSwift-高阶函数（上）给你们介绍 RxSwift 很是重要的高阶函数，也很少说，开始介绍服务器

5：从可观察对象的错误通知中恢复的操做符

5.1：catchErrorJustReturn

  • 从错误事件中恢复，方法是返回一个可观察到的序列，该序列发出单个元素，而后终止
print("*****catchErrorJustReturn*****")
let sequenceThatFails = PublishSubject<String>()

sequenceThatFails
    .catchErrorJustReturn("Cooci")
    .subscribe { print($0) }
    .disposed(by: disposeBag)

sequenceThatFails.onNext("Hank")
sequenceThatFails.onNext("Kody") // 正常序列发送成功的
//发送失败的序列,一旦订阅到位 返回咱们以前设定的错误的预案
sequenceThatFails.onError(self.lgError) 
复制代码

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("Hank")
sequenceThatFails.onNext("Kody") // 正常序列发送成功的
sequenceThatFails.onError(lgError) // 发送失败的序列

recoverySequence.onNext("CC")
复制代码

5.3：retry

  • 经过无限地从新订阅可观察序列来恢复重复的错误事件
print("*****retry*****")
var count = 1 // 外界变量控制流程
let sequenceRetryErrors = Observable<String>.create { observer in
    observer.onNext("Hank")
    observer.onNext("Kody")
    observer.onNext("CC")
    
    if count == 1 { 
        // 流程进来以后就会过分-这里的条件能够做为出口,失败的次数
        observer.onError(self.lgError)  // 接收到了错误序列,重试序列发生
        print("错误序列来了")
        count += 1
    }
    
    observer.onNext("Lina")
    observer.onNext("小雁子")
    observer.onNext("婷婷")
    observer.onCompleted()
    
    return Disposables.create()
}

sequenceRetryErrors
    .retry()
    .subscribe(onNext: { print($0) })
    .disposed(by: disposeBag)
复制代码

5.4：retry(_:):

  • 经过从新订阅可观察到的序列，重复地从错误事件中恢复，直到重试次数达到max未遂计数
print("*****retry(_:)*****")
let sequenceThatErrors = Observable<String>.create { observer in
    observer.onNext("Hank")
    observer.onNext("Kody")
    observer.onNext("CC")
    
    if count < 5 { // 这里设置的错误出口是没有太多意义的额,由于咱们设置重试次数
        observer.onError(self.lgError)
        print("错误序列来了")
        count += 1
    }
    
    observer.onNext("Lina")
    observer.onNext("小雁子")
    observer.onNext("婷婷")
    observer.onCompleted()
    
    return Disposables.create()
}

sequenceThatErrors
    .retry(3)
    .subscribe(onNext: { print($0) })
    .disposed(by: disposeBag)
复制代码

6：Rx流程操做符。

6.1：debug

  • 打印全部订阅、事件和处理。
print("*****debug*****")
var count = 1

let sequenceThatErrors = Observable<String>.create { observer in
    observer.onNext("Hank")
    observer.onNext("Kody")
    observer.onNext("CC")
    
    if count < 5 {
        observer.onError(self.lgError)
        print("错误序列来了")
        count += 1
    }
    
    observer.onNext("Lina")
    observer.onNext("小雁子")
    observer.onNext("可心")
    observer.onCompleted()
    
    return Disposables.create()
}

sequenceThatErrors
    .retry(3)
    .debug()
    .subscribe(onNext: { print($0) })
    .disposed(by: disposeBag)
复制代码

6.2： RxSwift.Resources.total:

  • 提供全部Rx资源分配的计数，这对于在开发期间检测泄漏很是有用。
print("*****RxSwift.Resources.total*****")

print(RxSwift.Resources.total)

let subject = BehaviorSubject(value: "Cooci")

let subscription1 = subject.subscribe(onNext: { print($0) })

print(RxSwift.Resources.total)

let subscription2 = subject.subscribe(onNext: { print($0) })

print(RxSwift.Resources.total)

subscription1.dispose()

print(RxSwift.Resources.total)

subscription2.dispose()

print(RxSwift.Resources.total)
复制代码

7：连接操做符

7.1：multicast

  • 将源可观察序列转换为可链接序列，并经过指定的主题广播其发射。
func testMulticastConnectOperators(){
    print("*****multicast*****")
    let subject = PublishSubject<Any>()
    subject.subscribe{print("00:\($0)")}
        .disposed(by: disposeBag)
    
    let netOB = Observable<Any>.create { (observer) -> Disposable in
            sleep(2)// 模拟网络延迟
            print("我开始请求网络了")
            observer.onNext("请求到的网络数据")
            observer.onNext("请求到的本地")
            observer.onCompleted()
            return Disposables.create {
                print("销毁回调了")
            }
        }.publish()
    
    netOB.subscribe(onNext: { (anything) in
            print("订阅1:",anything)
        })
        .disposed(by: disposeBag)

    // 咱们有时候不止一次网络订阅,由于有时候咱们的数据可能用在不一样的额地方
    // 因此在订阅一次 会出现什么问题?
    netOB.subscribe(onNext: { (anything) in
            print("订阅2:",anything)
        })
        .disposed(by: disposeBag)
    
    _ = netOB.connect()
}
复制代码
  • 底层逻辑探索中间变量ConnectableObservableAdapter保存了源序列source、中间序列makeSubject
  • 订阅流程self.lazySubject.subscribe(observer)一个懒加载的序列，保证了中间变量ConnectableObservableAdapter每一次都是同一个响应序列
  • 剩下就是PublishSubject的订阅效果
  • 完事等待源序列的响应，可是咱们的源序列的订阅是在connect函数里面！若是没有调用connect函数，意味着就永远不会发送响应。这样背后的逻辑就是，前面因此的发送响应在connect函数以前的都没有任何的意义！
  • 以上也就说明了咱们的publish就是状态共享的：connnect一次咱们序列发送一次响应（响应全部订阅）。

7.2：replay

  • 将源可观察序列转换为可链接的序列，并将向每一个新订阅服务器重放之前排放的缓冲大小
  • 首先拥有和publish同样的能力，共享 Observable sequence， 其次使用replay还须要咱们传入一个参数（buffer size）来缓存已发送的事件，当有新的订阅者订阅了，会把缓存的事件发送给新的订阅者
func testReplayConnectOperators(){   
    print("*****replay*****")

    let interval = Observable<Int>.interval(.seconds(1), scheduler: MainScheduler.instance).replay(5)
    
    interval.subscribe(onNext: { print(Date.time,"订阅: 1, 事件: \($0)") })
        .disposed(by: self.disposeBag)
    
    delay(2) { _ = interval.connect() }
    
    delay(4) {
        interval.subscribe(onNext: { print(Date.time,"订阅: 2, 事件: \($0)") })
            .disposed(by: self.disposeBag)
    }
    
    delay(8) {
        interval.subscribe(onNext: { print(Date.time,"订阅: 3, 事件: \($0)") })
            .disposed(by: self.disposeBag)
    }
    delay(20, closure: {
        self.disposeBag = DisposeBag()
    })
    
    /** 订阅: 1, 事件: 4 订阅: 1, 事件: 0 2019-05-28 21-32-42 订阅: 2, 事件: 0 2019-05-28 21-32-42 订阅: 1, 事件: 1 2019-05-28 21-32-42 订阅: 2, 事件: 1 2019-05-28 21-32-45 订阅: 2, 事件: 4 2019-05-28 21-32-46 订阅: 3, 事件: 0 2019-05-28 21-32-46 订阅: 3, 事件: 1 2019-05-28 21-32-46 订阅: 3, 事件: 2 2019-05-28 21-32-46 订阅: 3, 事件: 3 2019-05-28 21-32-46 订阅: 3, 事件: 4 // 序列从 0开始 // 定时器也没有断层 sub2 sub3 和 sub1 是同步的 */
}
复制代码

高阶函数的用法仍是有点意思的！若是你是一个RxSwift新手，仍是很是建议你们耐着性子好好练习，对你的开发绝对有帮助!网络

就问此时此刻还有谁？45度仰望天空，该死！我这无处安放的魅力！闭包

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程