def test_all_return(self):
        scheduler = TestScheduler()
        msgs = [on_next(150, 1), on_next(210, 2), on_completed(250)]
        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_next(250, True), on_completed(250))
dataset/ETHPy150Open ReactiveX/RxPY/tests/test_observable/test_all.py/TestAll.test_all_return/operator `>` -> `==`