From 988bcbb8842d12202f278808698a6b546718e764 Mon Sep 17 00:00:00 2001
From: Yoshiya Hinosawa <stibium121@gmail.com>
Date: Sat, 22 Jun 2019 23:22:27 +0900
Subject: [PATCH] fetch: make body async iterable (#2563)

---
 js/fetch.ts      |  4 ++++
 js/fetch_test.ts | 11 +++++++++++
 2 files changed, 15 insertions(+)

diff --git a/js/fetch.ts b/js/fetch.ts
index b1cd8f4aad..d5f01b8707 100644
--- a/js/fetch.ts
+++ b/js/fetch.ts
@@ -237,6 +237,10 @@ class Body implements domTypes.Body, domTypes.ReadableStream, io.ReadCloser {
   tee(): [domTypes.ReadableStream, domTypes.ReadableStream] {
     return notImplemented();
   }
+
+  [Symbol.asyncIterator](): AsyncIterableIterator<Uint8Array> {
+    return io.toAsyncIterator(this);
+  }
 }
 
 export class Response implements domTypes.Response {
diff --git a/js/fetch_test.ts b/js/fetch_test.ts
index b93f7845a0..032727dbc0 100644
--- a/js/fetch_test.ts
+++ b/js/fetch_test.ts
@@ -33,6 +33,17 @@ testPerm({ net: true }, async function fetchBlob(): Promise<void> {
   assertEquals(blob.size, Number(headers.get("Content-Length")));
 });
 
+testPerm({ net: true }, async function fetchAsyncIterator(): Promise<void> {
+  const response = await fetch("http://localhost:4545/package.json");
+  const headers = response.headers;
+  let total = 0;
+  for await (const chunk of response.body) {
+    total += chunk.length;
+  }
+
+  assertEquals(total, Number(headers.get("Content-Length")));
+});
+
 testPerm({ net: true }, async function responseClone(): Promise<void> {
   const response = await fetch("http://localhost:4545/package.json");
   const response1 = response.clone();