def test_count_predicate_some_none(self):
        scheduler = TestScheduler()
        xs = scheduler.create_hot_observable(on_next(150, 1), on_next(210, 2), on_next(220, 3), on_next(230, 4), on_completed(250))

        def create():
            return xs.count(lambda x: x > 10)

        res = scheduler.start(create=create)

        res.messages.assert_equal(on_next(250, 0), on_completed(250))
        xs.subscriptions.assert_equal(subscribe(200, 250))
dataset/ETHPy150Open ReactiveX/RxPY/tests/test_observable/test_count.py/TestCount.test_count_predicate_some_none/original