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(results) == 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/original