forked from Reactive-Extensions/RxJS
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathpairs.js
More file actions
45 lines (35 loc) · 1.07 KB
/
Copy pathpairs.js
File metadata and controls
45 lines (35 loc) · 1.07 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
(function () {
QUnit.module('pairs');
var TestScheduler = Rx.TestScheduler,
Observable = Rx.Observable;
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('pairs empty', function () {
var scheduler = new TestScheduler();
var xs = {};
var results = scheduler.startWithCreate(function () {
return Observable.pairs(xs, scheduler);
});
results.messages.assertEqual(
onCompleted(201)
);
});
test('pairs normal', function () {
var scheduler = new TestScheduler();
var xs = {foo: 42, bar: 56, baz: 78};
var results = scheduler.startWithCreate(function () {
return Observable.pairs(xs, scheduler);
});
results.messages.assertEqual(
onNext(201, ['foo', 42]),
onNext(202, ['bar', 56]),
onNext(203, ['baz', 78]),
onCompleted(204)
);
});
}());