

def test_on_error_resume_next_single_source_throws(self):
    ex = 'ex'
    scheduler = TestScheduler()
    msgs1 = [on_error(230, ex)]
    o1 = results.create_hot_observable(msgs1)

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

dataset/ETHPy150Open ReactiveX/RxPY/tests/test_observable/test_onerrorresumenext.py TestOnErrorResumeNext.test_on_error_resume_next_single_source_throws/VarMisuse@33/48 `scheduler`->`results`