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