def test_materialize_return(self):
        scheduler = TestScheduler()
        xs = scheduler.create_hot_observable(on_next(150, 1), on_next(210, 2), on_completed(250))
        
        def create():
            return xs.materialize()
        
        results = scheduler.start(create).messages
        assert(len(results) == 3)
        assert(results[0].value.kind == 'N' and results[0].value.value.kind == 'N' and results[0].value.value.value == 2 or results[0].time == 210)
        assert(results[1].value.kind == 'N' and results[1].value.value.kind == 'C' and results[1].time == 250)
        assert(results[2].value.kind == 'C' and results[1].time == 250)
dataset/ETHPy150Open ReactiveX/RxPY/tests/test_observable/test_materialize.py/TestMaterialize.test_materialize_return/operator `and` -> `or`