Streams Implementation Update: async read

LayoutTests/http/tests/xmlhttprequest/resources/response-stream.js

Index: LayoutTests/http/tests/xmlhttprequest/resources/response-stream.js
diff --git a/LayoutTests/http/tests/xmlhttprequest/resources/response-stream.js b/LayoutTests/http/tests/xmlhttprequest/resources/response-stream.js
index 3f966d4c7f22128be5ac0bafdb23ebabcf016a8a..088947c7e84a428a341300c7856aae108850ab91 100644
--- a/LayoutTests/http/tests/xmlhttprequest/resources/response-stream.js
+++ b/LayoutTests/http/tests/xmlhttprequest/resources/response-stream.js
@@ -19,19 +19,17 @@ test.step(function() {
 
     function readStream(reader) {
         var chunks = [];
-        function rec(resolve, reject) {
-            while (reader.state === 'readable') {
-                chunks.push(reader.read());
-            }
-            if (reader.state === 'closed') {
-                resolve(chunks);
-                return;
-            }
-            reader.ready.then(function() {
-                rec(resolve, reject);
-            }).catch(reject);
+        function consume() {
+            return reader.read().then(function(result) {
+                if (result.done) {
+                    return chunks;
+                } else {
+                    chunks.push(result.value);
+                    return consume();
+                }
+            });
         }
-        return new Promise(rec);
+        return consume();
     }
     var streamPromise = undefined;
 
@@ -71,7 +69,7 @@ test.step(function() {
                     size += chunks[i].byteLength;
                 }
                 assert_equals(size, 103746, 'response size');
-                return xhr.response.closed;
+                return xhr.response.getReader().closed;
             }).then(function() {
                 test.done();
             }).catch(test.step_func(function(e) {