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
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
|
test(() => {
const results = [];
const source = new Observable(subscriber => {
subscriber.addTeardown(() => results.push("source teardown"));
subscriber.next(1);
subscriber.next(2);
subscriber.next(3);
subscriber.complete();
});
const result = source.take(2);
result.subscribe({
next: v => results.push(v),
error: e => results.push(e),
complete: () => results.push("complete"),
});
assert_array_equals(results, [1, 2, "source teardown", "complete"]);
}, "take(): Takes the first N values from the source observable, then completes");
test(() => {
const results = [];
const source = new Observable(subscriber => {
subscriber.addTeardown(() => results.push("source teardown"));
subscriber.next(1);
subscriber.next(2);
subscriber.next(3);
subscriber.complete();
});
const result = source.take(5);
result.subscribe({
next: v => results.push(v),
error: e => results.push(e),
complete: () => results.push("complete"),
});
assert_array_equals(results, [1, 2, 3, "source teardown", "complete"],
"complete() is immediately forwarded");
}, "take(): Forwards complete()s that happen before the take count is met, " +
"and unsubscribes from source Observable");
test(() => {
const results = [];
const error = new Error('source error');
const source = new Observable(subscriber => {
subscriber.next(1);
subscriber.error(error);
});
const result = source.take(100);
result.subscribe({
next: v => results.push(v),
error: e => results.push(e),
complete: () => results.push("complete"),
});
assert_array_equals(results, [1, error], "Errors are forwarded");
}, "take(): Should forward errors from the source observable");
test(() => {
const results = [];
const source = new Observable((subscriber) => {
results.push("source subscribe");
subscriber.next(1);
subscriber.next(2);
subscriber.next(3);
subscriber.complete();
});
const result = source.take(0);
result.subscribe({
next: v => results.push(v),
error: e => results.push(e),
complete: () => results.push("complete"),
});
assert_array_equals(results, ["complete"]);
}, "take(): take(0) should not subscribe to the source observable, and " +
"should return an observable that immediately completes");
test(() => {
const results = [];
const source = new Observable((subscriber) => {
results.push("source subscribe");
subscriber.next(1);
subscriber.next(2);
subscriber.next(3);
subscriber.complete();
});
// Per WebIDL, `-1` passed into an `unsigned long long` gets wrapped around
// into the maximum value (18446744073709551615), which means the `result`
// Observable captures everything that `source` does.
const result = source.take(-1);
result.subscribe({
next: v => results.push(v),
error: e => results.push(e),
complete: () => results.push("complete"),
});
assert_array_equals(results, ["source subscribe", 1, 2, 3, "complete"]);
}, "take(): Negative count is treated as maximum value");
|
