forked from Reactive-Extensions/RxJS
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathrange.js
More file actions
53 lines (48 loc) · 1.7 KB
/
Copy pathrange.js
File metadata and controls
53 lines (48 loc) · 1.7 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
QUnit.module('Range');
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('Range_Zero', function () {
var results, scheduler;
scheduler = new TestScheduler();
results = scheduler.startWithCreate(function () {
return Observable.range(0, 0, scheduler);
});
results.messages.assertEqual(onCompleted(201));
});
test('Range_One', function () {
var results, scheduler;
scheduler = new TestScheduler();
results = scheduler.startWithCreate(function () {
return Observable.range(0, 1, scheduler);
});
results.messages.assertEqual(onNext(201, 0), onCompleted(202));
});
test('Range_Five', function () {
var results, scheduler;
scheduler = new TestScheduler();
results = scheduler.startWithCreate(function () {
return Observable.range(10, 5, scheduler);
});
results.messages.assertEqual(
onNext(201, 10),
onNext(202, 11),
onNext(203, 12),
onNext(204, 13),
onNext(205, 14),
onCompleted(206));
});
test('Range_Dispose', function () {
var results, scheduler;
scheduler = new TestScheduler();
results = scheduler.startWithDispose(function () {
return Observable.range(-10, 5, scheduler);
}, 204);
results.messages.assertEqual(onNext(201, -10), onNext(202, -9), onNext(203, -8));
});