RxSwift操作符merge、zip、combinLatest的使用-阿里云开发者社区

RxSwift操作符merge、zip、combinLatest的使用

2023-09-03 250

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： RxSwift操作符merge、zip、combinLatest的使用

01. Merge

merge的特征

1. 通过使用merge操作符你可以将多个Observables合并成一个，当某一个Observable发出一个元素时，他就将这个元素发出。

2. 如果某一个Observable发出一个onError事件，那么被合并的Observable也会将它发出，并且立即终止序列。

3. 如果某一个Observable发出一个onCompleted事件，发出这个onCompleted事件的序列之后将无法发出元素，其他Observable可以继续正常发出元素，那么被合并的Observable会判断被合并的是否所有的Observable都onCompleted，如果都onCompleted，则被合并的Observable也会发出onCompleted，并且立即终止序列。

func merge() {
    let publishSubject1 = PublishSubject<String>()
    let publishSubject2 = PublishSubject<String>()
    Observable.of(publishSubject1, publishSubject2).merge().subscribe { (ele) in
        print(ele)
    } onError: { (error) in
        print("error - ", error)
    } onCompleted: {
        print("oncompleted")
    } onDisposed: {
    }.disposed(by: self.disposeBag)
    publishSubject1.onNext("1")
    publishSubject1.onNext("2")
    publishSubject2.onNext("A")
    publishSubject1.onNext("3")
    publishSubject2.onNext("B")
//        publishSubject1.onError(TestError.none)
    publishSubject1.onCompleted()
    publishSubject2.onNext("C")
    publishSubject2.onCompleted()
    publishSubject1.onNext("D")
    publishSubject2.onNext("E")
}

运行结果：

Log - 1
Log - 2
Log - A
Log - 3
Log - B
Log - C
Log - oncompleted

02. Zip

zip的特征

1. 通过一个函数将多个Observables的元素组合起来，然后将每一个组合的结果发出来

2. 如果某一个Observable发出一个onError事件，那么被zip的Observable也会将它发出，并且立即终止序列。

3. zip操作符将多个(最多不超过8个)Observables的元素通过一个函数组合起来，然后将这个组合的结果发出来。它会严格的按照序列的索引数进行组合。例如，返回的Observable的第一个元素，是由每一个源Observables的第一个元素组合出来的。它的第二个元素，是由每一个源Observables的第二个元素组合出来的。它的第三个元素，是由每一个源Observables的第三个元素组合出来的，以此类推。它的元素数量等于源Observables中元素数量最少的那个。

func zip() {
    let publishSubject1 = PublishSubject<String>()
    let publishSubject2 = PublishSubject<String>()
    Observable.zip(publishSubject1, publishSubject2).subscribe { (ele) in
        Logger("\(ele.0) - \(ele.1)")
    } onError: { (error) in
        Logger("error - \(error)")
    } onCompleted: {
        Logger("oncompleted")
    } onDisposed: {
    }.disposed(by: self.disposeBag)
    publishSubject1.onNext("1")
    publishSubject1.onNext("2")
    publishSubject2.onNext("A")
//        publishSubject2.onCompleted()
    publishSubject1.onNext("3")
    publishSubject2.onNext("B")
    publishSubject1.onNext("4")
//    publishSubject1.onError(TestError.none)
//    publishSubject1.onCompleted()
//    publishSubject2.onCompleted()
    publishSubject2.onNext("C")
    publishSubject1.onNext("4")
    publishSubject2.onNext("D")
}

运行结果：

Log - 1 - A
Log - 2 - B
Log - 3 - C
Log - 4 - D

03. combinLatest

combinLatest的特征

combineLatest操作符将多个Observables中最新的元素通过一个函数组合起来，然后将这个组合的结果发出来。这些源Observables中任何一个发出一个元素，他都会发出一个元素（前提是，这些 Observables 曾经发出过元素）

func combineLatest() {
    let publishSubject1 = PublishSubject<String>()
    let publishSubject2 = PublishSubject<String>()
    Observable.combineLatest(publishSubject1, publishSubject2).subscribe { (ele) in
        Logger(ele)
    } onError: { (error) in
        Logger("error - \(error)")
    } onCompleted: {
        Logger("oncompleted")
    } onDisposed: {
    }.disposed(by: self.disposeBag)
    publishSubject1.onNext("1")
//        publishSubject1.onError(TestError.none)
    publishSubject1.onNext("2")
    publishSubject2.onNext("A")
    publishSubject1.onNext("3")
    publishSubject2.onNext("B")
    publishSubject1.onNext("4")
    publishSubject2.onNext("C")
    publishSubject1.onNext("5")
}

运行结果：

Log - ("2", "A")
Log - ("3", "A")
Log - ("3", "B")
Log - ("4", "B")
Log - ("4", "C")
Log - ("5", "C")

文章标签：

索引

RxSwift操作符merge、zip、combinLatest的使用

热门文章

最新文章

相关电子书