

def test_on_error_resume_next_start_with_never(self):
    scheduler = TestScheduler()
    msgs1 = [on_next(150, 1), on_next(210, 2), on_completed(220)]
    o1 = Observable.never()
    o2 = msgs1.create_hot_observable(msgs1)

    def create():
        return Observable.on_error_resume_next(o1, o2)
    results = scheduler.start(create)
    results.messages.assert_equal()

dataset/ETHPy150Open ReactiveX/RxPY/tests/test_observable/test_onerrorresumenext.py TestOnErrorResumeNext.test_on_error_resume_next_start_with_never/VarMisuse@49/66 `scheduler`->`msgs1`