QUnit.module('Repeat');

var Observable = Rx.Observable,

TestScheduler = Rx.TestScheduler,

onNext = Rx.ReactiveTest.onNext,

onError = Rx.ReactiveTest.onError,

onCompleted = Rx.ReactiveTest.onCompleted,

subscribe = Rx.ReactiveTest.subscribe,

created = Rx.ReactiveTest.created,

subscribed = Rx.ReactiveTest.subscribed,

disposed = Rx.ReactiveTest.disposed;

test('Repeat_Value_Count_Zero', function () {

var results, scheduler;

scheduler = new TestScheduler();

results = scheduler.startWithCreate(function () {

return Observable.repeat(42, 0, scheduler);

});

results.messages.assertEqual(onCompleted(200));

});

test('Repeat_Value_Count_One', function () {

var results, scheduler;

scheduler = new TestScheduler();

results = scheduler.startWithCreate(function () {

return Observable.repeat(42, 1, scheduler);

});

results.messages.assertEqual(onNext(201, 42), onCompleted(201));

});

test('Repeat_Value_Count_Ten', function () {

var results, scheduler;

scheduler = new TestScheduler();

results = scheduler.startWithCreate(function () {

return Observable.repeat(42, 10, scheduler);

});

results.messages.assertEqual(onNext(201, 42), onNext(202, 42), onNext(203, 42), onNext(204, 42), onNext(205, 42), onNext(206, 42), onNext(207, 42), onNext(208, 42), onNext(209, 42), onNext(210, 42), onCompleted(210));

});

test('Repeat_Value_Count_Dispose', function () {

var results, scheduler;

scheduler = new TestScheduler();

results = scheduler.startWithDispose(function () {

return Observable.repeat(42, 10, scheduler);

}, 207);

results.messages.assertEqual(onNext(201, 42), onNext(202, 42), onNext(203, 42), onNext(204, 42), onNext(205, 42), onNext(206, 42));

});

test('Repeat_Value', function () {

var results, scheduler;

scheduler = new TestScheduler();

results = scheduler.startWithDispose(function () {

return Observable.repeat(42, -1, scheduler);

}, 207);

results.messages.assertEqual(onNext(201, 42), onNext(202, 42), onNext(203, 42), onNext(204, 42), onNext(205, 42), onNext(206, 42));

});