天天看點

RxSwift 操作符 (merge)merge

merge

ReactiveX:

combine multiple Observables into one by merging their emissions

該操作符将多個被觀察者合并起來,并能一次訂閱到他們的值。

let pb1 = PublishSubject<Int>()
let pb2 = PublishSubject<Int>()
Observable<Int>.merge(pb1, pb2)
    .subscribe(onNext: { p in
        print(p)
    })
    .disposed(by: bag)
pb1.onNext(2)
pb2.onNext(1)           

輸出: 2 1