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

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、reduce

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

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