diff options
author | Luca Casonato <hello@lcas.dev> | 2021-06-30 18:05:58 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-06-30 18:05:58 +0200 |
commit | de6e44794b7a95b6895a9aab907e01788820d18c (patch) | |
tree | 7cbfd339f1e67eed9886c50b803556ebe3031432 /cli/tests/unit | |
parent | 3e21ffc935a139f9cfa1ddfaeffd6429d53061ed (diff) |
fix: panic in request body streaming (#11191)
Diffstat (limited to 'cli/tests/unit')
-rw-r--r-- | cli/tests/unit/fetch_test.ts | 22 |
1 files changed, 22 insertions, 0 deletions
diff --git a/cli/tests/unit/fetch_test.ts b/cli/tests/unit/fetch_test.ts index cf7510ea2..46eceb50c 100644 --- a/cli/tests/unit/fetch_test.ts +++ b/cli/tests/unit/fetch_test.ts @@ -3,6 +3,7 @@ import { assert, assertEquals, assertThrowsAsync, + deferred, fail, unimplemented, unitTest, @@ -1195,3 +1196,24 @@ unitTest( assertEquals(response.headers.get("Host"), addr); }, ); + +unitTest( + { perms: { net: true } }, + async function fetchNoServerReadableStreamBody() { + const done = deferred(); + const body = new ReadableStream({ + start(controller) { + controller.enqueue(new Uint8Array([1])); + setTimeout(() => { + controller.enqueue(new Uint8Array([2])); + done.resolve(); + }, 1000); + }, + }); + const nonExistantHostname = "http://localhost:47582"; + await assertThrowsAsync(async () => { + await fetch(nonExistantHostname, { body, method: "POST" }); + }, TypeError); + await done; + }, +); |