8. RxSwift 插入发送合并压缩 startWith、merge、zip

2021-03-14 19:32

阅读：678

标签：插入 tps lis scribe 操作 with let zip publish

startWith

在订阅的时候插入发送事件，后加入的先发送。完成事件发送时不会插入。

let ob = PublishSubject()
ob.startWith("插入1").startWith("插入2").subscribe(onNext: { element in
    print(element)
}).disposed(by: disposeBag)
ob.onNext("发送1")
插入2
插入1
发送1

merge

合并操作，将多个 Observable 合并成一个

let ob1 = PublishSubject()
let ob2 = PublishSubject()
Observable.of(ob1,ob2).merge().subscribe { (event) in
    print(event)
}.disposed(by: disposeBag)
ob1.onNext("ob1 发1")
ob2.onNext("ob2 发1")
ob1.onNext("ob1 发2")
ob2.onNext("ob2 发2")

zip

将 n 个Observable压缩成一个发送事件，必须每个都参与的发送完才会发送一次事件。参与的成对发送完

let ob1 = PublishSubject()
let ob2 = PublishSubject()
Observable.zip(ob1,ob2).subscribe { (event) in
    print(event)
}

ob1.onNext("ob1  2")
ob1.onNext("ob1  3")
ob2.onNext("ob2  A")
ob2.onNext("ob2  B")
ob2.onNext("ob2  C")
ob1.onNext("ob1  1")

//next(("ob1  2", "ob2  A"))
//next(("ob1  3", "ob2  B"))
//next(("ob1  1", "ob2  C"))

搬迁自本人简书

8. RxSwift 插入发送合并压缩 startWith、merge、zip

标签：插入 tps lis scribe 操作 with let zip publish

原文地址：https://www.cnblogs.com/i2yf/p/14016628.html

上一篇：16.python邮件发送

下一篇：Spring内置的定时任务调度@Scheduled

文章来自：搜素材网的编程语言模块，转载请注明文章出处。
文章标题：8. RxSwift 插入发送合并压缩 startWith、merge、zip
文章链接：http://soscw.com/essay/64674.html

亲，登录后才可以留言！

8. RxSwift 插入发送合并压缩 startWith、merge、zip

startWith

merge

zip

评论

热门文章

推荐文章

最新文章

置顶文章