記錄一個(gè)小小測(cè)試結(jié)果

merge 將多個(gè)sequences 合并為一個(gè)sequence

let subject1 = PublishSubject<Int>()
        let subject2 = PublishSubject<Int>()
        
        Observable.of(subject1, subject2)
            .merge()
            .subscribe {
                print($0)
        }.addDisposableTo(disposeBag)
        
        let e = myError()
        subject1.onNext(10)
        subject1.on(.next(10))
        subject1.on(.next(11))
        subject1.on(.next(12))
        subject2.on(.next(20))
        subject2.on(.next(21))
        subject1.on(.next(14))
        subject1.on(.error(e))// 只要出現(xiàn)error 所有流均終止
        subject2.on(.next(22))
        subject2.on(.completed)

輸出結(jié)果:

next(10)
next(10)
next(11)
next(12)
next(20)
next(21)
next(14)
error(myError())

只要任意sequence 遇到error 就會(huì)中斷所有sequence