

def test_on_error_resume_next_error_multiple(self):
    scheduler = TestScheduler()
    msgs1 = [on_next(150, 1), on_next(210, 2), on_error(220, 'ex')]
    msgs2 = [on_next(230, 4), on_error(240, 'ex')]
    msgs3 = [on_completed(250)]
    o1 = scheduler.create_hot_observable(msgs1)
    o2 = scheduler.create_hot_observable(msgs2)
    o3 = scheduler.create_hot_observable(msgs3)

    def create():
        return Observable.on_error_resume_next(o1, o2, o3)
    results = scheduler.start(create)
    results.messages.assert_equal(on_next(210, 2), on_next(230, 4), on_completed(250))

dataset/ETHPy150Open ReactiveX/RxPY/tests/test_observable/test_onerrorresumenext.py TestOnErrorResumeNext.test_on_error_resume_next_error_multiple/original