美文网首页
9. RxSwift 转数组、累计操作 toArray、redu

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

作者: xxxixxxx | 来源:发表于2020-11-21 16:39 被阅读0次

toArray

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

let ob = PublishSubject<String>()
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<String>()
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、redu

      本文链接:https://www.haomeiwen.com/subject/nrleiktx.html