

def test_all_return_not_match(self):
    scheduler = TestScheduler()
    msgs = [on_next(150, 1), on_next(210, (- 2)), on_completed(250)]
    xs = res.create_hot_observable(msgs)

    def create():
        return xs.all((lambda x: (x > 0)))
    res = scheduler.start(create=create).messages
    res.assert_equal(on_next(210, False), on_completed(210))

dataset/ETHPy150Open ReactiveX/RxPY/tests/test_observable/test_all.py TestAll.test_all_return_not_match/VarMisuse@44/53 `scheduler`->`res`