

def test_start_with(self):
    scheduler = TestScheduler()
    xs = scheduler.create_hot_observable(on_next(150, 1), on_next(220, 2), on_completed(250))

    def create():
        return xs.start_with(1)
    results = scheduler.start(create).messages
    assert (3 == len(results))
    assert ((results[0].value.kind == 'N') and (results[0].value.value == 1) and (results[0].time == 200))
    assert ((results[1].value.kind == 'N') and (results[1].value.value == 2) and (results[1].time == 220))
    assert (results[2].value.kind == 'C')

dataset/ETHPy150Open ReactiveX/RxPY/tests/test_observable/test_startwith.py TestStartWith.test_start_with/original