

def test_materialize_throw(self):
    ex = 'ex'
    scheduler = TestScheduler()
    xs = scheduler.create_hot_observable(on_next(150, 1), on_error(250, ex))

    def create():
        return xs.materialize()
    results = scheduler.start(create).messages
    assert (len(xs) == 2)
    assert ((results[0].value.kind == 'N') and (results[0].value.value.kind == 'E') and (results[0].value.value.exception == ex))
    assert (results[1].value.kind == 'C')

dataset/ETHPy150Open ReactiveX/RxPY/tests/test_observable/test_materialize.py TestMaterialize.test_materialize_throw/VarMisuse@72/88 `results`->`xs`