Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(94)

Side by Side Diff: LayoutTests/http/tests/fetch/script-tests/stream-reader.js

Issue 1053503002: [Fetch] Response.clone should tee the body stream. (Closed) Base URL: https://chromium.googlesource.com/chromium/blink.git@master
Patch Set: Created 5 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « LayoutTests/http/tests/fetch/script-tests/response.js ('k') | Source/modules/fetch/Body.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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 consume() { 7 function consume() {
8 return reader.read().then(function(r) { 8 return reader.read().then(function(r) {
9 if (r.done) { 9 if (r.done) {
10 return chunks; 10 return chunks;
(...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after
98 reader = res.body.getReader(); 98 reader = res.body.getReader();
99 return reader.read(); 99 return reader.read();
100 }).then(function(r) { 100 }).then(function(r) {
101 assert_false(r.done); 101 assert_false(r.done);
102 read += r.value.byteLength; 102 read += r.value.byteLength;
103 // Make sure that we received something but we didn't receive all. 103 // Make sure that we received something but we didn't receive all.
104 assert_not_equals(read, 0); 104 assert_not_equals(read, 0);
105 assert_not_equals(read, 190); 105 assert_not_equals(read, 190);
106 106
107 reader.releaseLock(); 107 reader.releaseLock();
108 return read_until_end(original.clone().body.getReader()); 108 var original_body = original.body;
109 }).then(function(chunks) { 109 var clone = original.clone();
110 for (var chunk of chunks) { 110 assert_not_equals(original.body, clone.body);
111 read += chunk.byteLength; 111 assert_not_equals(original.body, original_body);
112 assert_not_equals(clone.body, original_body);
113 assert_throws({name: 'TypeError'}, function() {
114 original_body.getReader();
115 });
116 var reader1 = original.body.getReader();
117 var reader2 = clone.body.getReader();
118 return Promise.all([read_until_end(reader1), read_until_end(reader2)]);
119 }).then(function(r) {
120 var read1 = 0;
121 var read2 = 0;
122 for (var chunk of r[0]) {
123 read1 += chunk.byteLength;
124 }
125 for (var chunk of r[1]) {
126 read2 += chunk.byteLength;
112 } 127 }
113 // Make sure that we received all data in total. 128 // Make sure that we received all data in total.
114 assert_equals(read, 190); 129 assert_equals(read + read1, 190);
130 assert_equals(read + read2, 190);
115 }); 131 });
116 }, 'Clone after reading partially'); 132 }, 'Clone after reading partially');
117 133
118 sequential_promise_test(function(t) { 134 sequential_promise_test(function(t) {
119 return fetch('/fetch/resources/progressive.php').then(function(res) { 135 return fetch('/fetch/resources/progressive.php').then(function(res) {
120 res.body.cancel(); 136 res.body.cancel();
121 return res.text(); 137 return res.text();
122 }).then(function(text) { 138 }).then(function(text) {
123 assert_equals(text, ''); 139 assert_equals(text, '');
124 }); 140 });
(...skipping 21 matching lines...) Expand all
146 assert_equals(text.length, 190); 162 assert_equals(text.length, 190);
147 return stream.getReader().read(); 163 return stream.getReader().read();
148 }).then(function(r) { 164 }).then(function(r) {
149 assert_true(r.done); 165 assert_true(r.done);
150 assert_equals(r.value, undefined); 166 assert_equals(r.value, undefined);
151 }); 167 });
152 }, 'Accessing body when processing text().'); 168 }, 'Accessing body when processing text().');
153 169
154 sequential_promise_test_done(); 170 sequential_promise_test_done();
155 done(); 171 done();
OLDNEW
« no previous file with comments | « LayoutTests/http/tests/fetch/script-tests/response.js ('k') | Source/modules/fetch/Body.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698