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
|
// META: global=window,worker
// META: script=../resources/test-utils.js
// META: script=../resources/recording-streams.js
'use strict';
function interceptThen() {
const intercepted = [];
let callCount = 0;
Object.prototype.then = function(resolver) {
if (!this.done) {
intercepted.push(this.value);
}
const retval = Object.create(null);
retval.done = ++callCount === 3;
retval.value = callCount;
resolver(retval);
if (retval.done) {
delete Object.prototype.then;
}
}
return intercepted;
}
promise_test(async t => {
const rs = new ReadableStream({
start(controller) {
controller.enqueue('a');
controller.close();
}
});
const ws = recordingWritableStream();
const intercepted = interceptThen();
t.add_cleanup(() => {
delete Object.prototype.then;
});
await rs.pipeTo(ws);
delete Object.prototype.then;
assert_array_equals(intercepted, [], 'nothing should have been intercepted');
assert_array_equals(ws.events, ['write', 'a', 'close'], 'written chunk should be "a"');
}, 'piping should not be observable');
promise_test(async t => {
const rs = new ReadableStream({
start(controller) {
controller.enqueue('a');
controller.close();
}
});
const ws = recordingWritableStream();
const [ branch1, branch2 ] = rs.tee();
const intercepted = interceptThen();
t.add_cleanup(() => {
delete Object.prototype.then;
});
await branch1.pipeTo(ws);
delete Object.prototype.then;
branch2.cancel();
assert_array_equals(intercepted, [], 'nothing should have been intercepted');
assert_array_equals(ws.events, ['write', 'a', 'close'], 'written chunk should be "a"');
}, 'tee should not be observable');
|
