

def test_on_error_resume_next_empty_return_throw_and_more(self):
    scheduler = TestScheduler()
    msgs1 = [on_next(150, 1), on_completed(205)]
    msgs2 = [on_next(215, 2), on_completed(220)]
    msgs3 = [on_next(225, 3), on_next(230, 4), on_completed(235)]
    msgs4 = [on_error(240, 'ex')]
    msgs5 = [on_next(245, 5), on_completed(250)]
    o1 = scheduler.create_hot_observable(msgs1)
    o2 = scheduler.create_hot_observable(msgs2)
    o3 = scheduler.create_hot_observable(msgs3)
    o4 = scheduler.create_hot_observable(msgs4)
    o5 = scheduler.create_hot_observable(msgs5)

    def create():
        return Observable.on_error_resume_next(o1, o2, o3, o4, o5)
    results = scheduler.start(create)
    results.messages.assert_equal(on_next(215, 2), on_next(225, 3), on_next(230, 4), on_next(245, 5), on_completed(250))

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