

def test_all_never(self):
    scheduler = TestScheduler()
    msgs = [on_next(150, 1)]
    xs = scheduler.create_hot_observable(msgs)

    def create():
        return xs.all((lambda x: (x > 0)))
    res = xs.start(create=create).messages
    res.assert_equal()

dataset/ETHPy150Open ReactiveX/RxPY/tests/test_observable/test_all.py TestAll.test_all_never/VarMisuse@64/74 `scheduler`->`xs`