diff options
Diffstat (limited to 'js')
-rw-r--r-- | js/fetch.ts | 4 | ||||
-rw-r--r-- | js/fetch_test.ts | 11 |
2 files changed, 15 insertions, 0 deletions
diff --git a/js/fetch.ts b/js/fetch.ts index b1cd8f4aa..d5f01b870 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 b93f7845a..032727dbc 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(); |