def test_all_throw(self):
        ex = 'ex'
        scheduler = TestScheduler()
        msgs = [on_next(150, 1), on_error(210, ex)]
        xs = scheduler.create_hot_observable(msgs)
    
        def create():
            return xs.all(lambda x: x != 0)
        res = scheduler.start(create=create).messages
        res.assert_equal(on_error(210, ex))
dataset/ETHPy150Open ReactiveX/RxPY/tests/test_observable/test_all.py/TestAll.test_all_throw/operator `>` -> `!=`