我的RxSwift
代码是,
func testOperators(){
let bag = DisposeBag()
let observable1 = PublishSubject<String>()
let observable2 = PublishSubject<String>()
Observable.concat([observable1, observable2])
.subscribe(onNext: { (value) in
print(value)
}).disposed(by: bag)
observable1.on(.next("1"))
observable1.on(.next("2"))
observable2.on(.next("3"))
observable2.on(.next("4"))
observable1.on(.completed)
observable2.on(.completed)
}
当前输出为,
1
2
我的预期输出是,
1
2
3
4
我想念什么?
ReplaySubject
,则它将重放为每个订阅者接收到的所有事件,并且您将获得所需的输出。