def test_window_with_time_or_count_disposed(self):
        scheduler = TestScheduler()
        xs = scheduler.create_hot_observable(on_next(205, 1), on_next(210, 2), on_next(240, 3), on_next(280, 4), on_next(320, 5), on_next(350, 6), on_next(370, 7), on_next(420, 8), on_next(470, 9), on_completed(600))
    
        def create():
            def projection(w, i):
                def inner_proj(x):
                    return "%s %s" % (i, x)
                return w.map(inner_proj)
            return xs.window_with_time_or_count(70, 3, scheduler).map(projection).merge_observable()
    
        results = scheduler.start(create, disposed=370)
        results.messages.assert_equal(on_next(205, "0 1"), on_next(210, "0 2"), on_next(240, "0 3"), on_next(280, "1 4"), on_next(320, "2 5"), on_next(350, "2 6"), on_next(370, "2 7"))
        xs.subscriptions.assert_equal(subscribe(200, 370))
dataset/ETHPy150Open ReactiveX/RxPY/tests/test_observable/test_windowwithtimeorcount.py/TestWindowWithTime.test_window_with_time_or_count_disposed/original