forked from Reactive-Extensions/RxJS
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathexpand.js
More file actions
87 lines (80 loc) · 3.19 KB
/
Copy pathexpand.js
File metadata and controls
87 lines (80 loc) · 3.19 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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
QUnit.module('Expand');
var Observable = Rx.Observable,
TestScheduler = Rx.TestScheduler,
onNext = Rx.ReactiveTest.onNext,
onError = Rx.ReactiveTest.onError,
onCompleted = Rx.ReactiveTest.onCompleted,
subscribe = Rx.ReactiveTest.subscribe;
function sequenceEqual(a1, a2) {
if (a1.length !== a2.length) {
return false;
}
for (var i = 0, len = a1.length; i < len; i++) {
if (a1[i] !== a2[i]) {
return false;
}
}
return true;
}
test('Expand_Empty', function () {
var results, scheduler, xs;
scheduler = new TestScheduler();
xs = scheduler.createHotObservable(onCompleted(300));
results = scheduler.startWithCreate(function () {
return xs.expand(function () {
return scheduler.createColdObservable(onNext(100, 1), onNext(200, 2), onCompleted(300));
}, scheduler);
});
results.messages.assertEqual(onCompleted(300));
xs.subscriptions.assertEqual(subscribe(201, 300));
});
test('Expand_Error', function () {
var ex, results, scheduler, xs;
scheduler = new TestScheduler();
ex = 'ex';
xs = scheduler.createHotObservable(onError(300, ex));
results = scheduler.startWithCreate(function () {
return xs.expand(function (x) {
return scheduler.createColdObservable(onNext(100 + x, 2 * x), onNext(200 + x, 3 * x), onCompleted(300 + x));
}, scheduler);
});
results.messages.assertEqual(onError(300, ex));
xs.subscriptions.assertEqual(subscribe(201, 300));
});
test('Expand_Never', function () {
var results, scheduler, xs;
scheduler = new TestScheduler();
xs = scheduler.createHotObservable();
results = scheduler.startWithCreate(function () {
return xs.expand(function (x) {
return scheduler.createColdObservable(onNext(100 + x, 2 * x), onNext(200 + x, 3 * x), onCompleted(300 + x));
}, scheduler);
});
results.messages.assertEqual();
xs.subscriptions.assertEqual(subscribe(201, 1000));
});
test('Expand_Basic', function () {
var results, scheduler, xs;
scheduler = new TestScheduler();
xs = scheduler.createHotObservable(onNext(550, 1), onNext(850, 2), onCompleted(950));
results = scheduler.startWithCreate(function () {
return xs.expand(function (x) {
return scheduler.createColdObservable(onNext(100, 2 * x), onNext(200, 3 * x), onCompleted(300));
}, scheduler);
});
results.messages.assertEqual(onNext(550, 1), onNext(651, 2), onNext(751, 3), onNext(752, 4), onNext(850, 2), onNext(852, 6), onNext(852, 6), onNext(853, 8), onNext(951, 4), onNext(952, 9), onNext(952, 12), onNext(953, 12), onNext(953, 12), onNext(954, 16));
xs.subscriptions.assertEqual(subscribe(201, 950));
});
test('Expand_Throw', function () {
var ex, results, scheduler, xs;
ex = 'ex';
scheduler = new TestScheduler();
xs = scheduler.createHotObservable(onNext(550, 1), onNext(850, 2), onCompleted(950));
results = scheduler.startWithCreate(function () {
return xs.expand(function (x) {
throw ex;
}, scheduler);
});
results.messages.assertEqual(onNext(550, 1), onError(550, ex));
xs.subscriptions.assertEqual(subscribe(201, 550));
});