9. RxSwift 转数组、累计操作 toArray、reduce

2021-03-15 01:30

阅读：994

标签：sub ring 一起发送 pos ext tor let lis

toArray

将所有的事件集合在一起作为一个数组发出，需要发送onCompleted事件

let ob = PublishSubject()
ob.toArray().subscribe { strArr in
    print(strArr)
} onError: { _ in
}.disposed(by: disposeBag)
ob.onNext("1")
ob.onNext("2")
ob.onNext("3")
ob.onCompleted()

reduce

累计操作，将每一次的事件都累积在一起在发送onCompleted时统一发送。

let ob = PublishSubject()
ob.reduce("初始值", accumulator: +).subscribe { event in
    print(event)
}.disposed(by: disposeBag)
ob.onNext("1")
ob.onNext("2")
ob.onNext("3")
ob.onCompleted()

搬迁自本人简书

9. RxSwift 转数组、累计操作 toArray、reduce

标签：sub ring 一起发送 pos ext tor let lis

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

上一篇：SpringBoot与监控

下一篇：【原创】Java并发编程系列29 | ConcurrentLinkedQueue

文章来自：搜素材网的编程语言模块，转载请注明文章出处。
文章标题：9. RxSwift 转数组、累计操作 toArray、reduce
文章链接：http://soscw.com/essay/64749.html

亲，登录后才可以留言！

9. RxSwift 转数组、累计操作 toArray、reduce

toArray

reduce

评论

热门文章

推荐文章

最新文章

置顶文章