summaryrefslogtreecommitdiff
path: root/cli/tests/unit/flash_test.ts
diff options
context:
space:
mode:
authorBartek IwaƄczuk <biwanczuk@gmail.com>2022-09-20 22:08:15 +0200
committerGitHub <noreply@github.com>2022-09-20 22:08:15 +0200
commit35fe9ee530b389f9249a7eccc2b0f91dc3cb414e (patch)
treec981e552d3210b44927600d96ca7a1c1c39fe1c8 /cli/tests/unit/flash_test.ts
parent2929ec9ffa70758f5481704e4de975dc61993f74 (diff)
fix(flash): panic if response if undefined (#15964)
Co-authored-by: Divy Srivastava <dj.srivastava23@gmail.com>
Diffstat (limited to 'cli/tests/unit/flash_test.ts')
-rw-r--r--cli/tests/unit/flash_test.ts30
1 files changed, 17 insertions, 13 deletions
diff --git a/cli/tests/unit/flash_test.ts b/cli/tests/unit/flash_test.ts
index 324830f8e..087e5d0f2 100644
--- a/cli/tests/unit/flash_test.ts
+++ b/cli/tests/unit/flash_test.ts
@@ -1085,24 +1085,27 @@ Deno.test("upgradeHttpRaw tcp", async () => {
const promise2 = deferred();
const ac = new AbortController();
const signal = ac.signal;
- const handler = async (req: Request) => {
- const [conn, _] = Deno.upgradeHttpRaw(req);
+ let conn: Deno.Conn;
+ let _head;
+ const handler = (req: Request) => {
+ [conn, _head] = Deno.upgradeHttpRaw(req);
- await conn.write(
- new TextEncoder().encode("HTTP/1.1 101 Switching Protocols\r\n\r\n"),
- );
+ (async () => {
+ await conn.write(
+ new TextEncoder().encode("HTTP/1.1 101 Switching Protocols\r\n\r\n"),
+ );
- promise.resolve();
+ promise.resolve();
- const buf = new Uint8Array(1024);
- const n = await conn.read(buf);
+ const buf = new Uint8Array(1024);
+ const n = await conn.read(buf);
- assert(n != null);
- const secondPacketText = new TextDecoder().decode(buf.slice(0, n));
- assertEquals(secondPacketText, "bla bla bla\nbla bla\nbla\n");
+ assert(n != null);
+ const secondPacketText = new TextDecoder().decode(buf.slice(0, n));
+ assertEquals(secondPacketText, "bla bla bla\nbla bla\nbla\n");
- promise2.resolve();
- conn.close();
+ promise2.resolve();
+ })();
};
const server = Deno.serve({
// NOTE: `as any` is used to bypass type checking for the return value
@@ -1131,6 +1134,7 @@ Deno.test("upgradeHttpRaw tcp", async () => {
);
await promise2;
+ conn!.close();
tcpConn.close();
ac.abort();