Merge

小さなテスト結果を記録merge複数のsequencesを1つのsequenceにマージ

let subject1 = PublishSubject()
        let subject2 = PublishSubject()
        
        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))//     error       
        subject2.on(.next(22))
        subject2.on(.completed)

出力結果:

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

任意のsequenceがerrorに遭遇するとすべてのsequenceが中断されます