OLD | NEW |
1 if (self.importScripts) { | 1 if (self.importScripts) { |
2 importScripts('/fetch/resources/fetch-test-helpers.js'); | 2 importScripts('/fetch/resources/fetch-test-helpers.js'); |
3 } | 3 } |
4 | 4 |
5 function read_until_end(reader) { | 5 function read_until_end(reader) { |
6 var chunks = []; | 6 var chunks = []; |
7 function rec(resolve, reject) { | 7 function rec(resolve, reject) { |
8 while (reader.state === 'readable') { | 8 while (reader.state === 'readable') { |
9 chunks.push(reader.read()); | 9 chunks.push(reader.read()); |
10 } | 10 } |
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
49 }); | 49 }); |
50 } | 50 } |
51 var stream; | 51 var stream; |
52 var reader; | 52 var reader; |
53 return fetch('/fetch/resources/doctype.html').then(function(res) { | 53 return fetch('/fetch/resources/doctype.html').then(function(res) { |
54 stream = res.body; | 54 stream = res.body; |
55 reader = stream.getReader(); | 55 reader = stream.getReader(); |
56 return wait_until_readable(reader); | 56 return wait_until_readable(reader); |
57 }).then(function() { | 57 }).then(function() { |
58 assert_equals(reader.state, 'readable'); | 58 assert_equals(reader.state, 'readable'); |
59 assert_equals(stream.state, 'waiting'); | |
60 reader.releaseLock(); | 59 reader.releaseLock(); |
61 assert_equals(reader.state, 'closed'); | 60 assert_equals(reader.state, 'closed'); |
62 assert_equals(stream.state, 'readable'); | |
63 var another = stream.getReader(); | 61 var another = stream.getReader(); |
64 assert_equals(reader.state, 'closed'); | 62 assert_equals(reader.state, 'closed'); |
65 assert_equals(stream.state, 'waiting'); | |
66 assert_equals(another.state, 'readable'); | 63 assert_equals(another.state, 'readable'); |
67 }); | 64 }); |
68 }, 'ExclusiveStreamReader state masking'); | 65 }, 'ExclusiveStreamReader state masking'); |
69 | 66 |
70 sequential_promise_test(function(t) { | 67 sequential_promise_test(function(t) { |
71 return fetch('/fetch/resources/doctype.html').then(function(res) { | 68 return fetch('/fetch/resources/doctype.html').then(function(res) { |
72 var reader = res.body.getReader(); | 69 var reader = res.body.getReader(); |
73 return read_until_end(reader); | 70 return read_until_end(reader); |
74 }).then(function(chunks) { | 71 }).then(function(chunks) { |
75 var size = 0; | 72 var size = 0; |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
107 res.body; | 104 res.body; |
108 assert_false(res.bodyUsed); | 105 assert_false(res.bodyUsed); |
109 res.text(); | 106 res.text(); |
110 assert_true(res.bodyUsed); | 107 assert_true(res.bodyUsed); |
111 assert_throws({name: 'TypeError'}, function() { res.body.getReader() }); | 108 assert_throws({name: 'TypeError'}, function() { res.body.getReader() }); |
112 }); | 109 }); |
113 }, 'Setting bodyUsed means the body is locked.'); | 110 }, 'Setting bodyUsed means the body is locked.'); |
114 | 111 |
115 sequential_promise_test_done(); | 112 sequential_promise_test_done(); |
116 done(); | 113 done(); |
OLD | NEW |