summaryrefslogtreecommitdiff
path: root/cli/tests/unit/net_test.ts
diff options
context:
space:
mode:
Diffstat (limited to 'cli/tests/unit/net_test.ts')
-rw-r--r--cli/tests/unit/net_test.ts48
1 files changed, 24 insertions, 24 deletions
diff --git a/cli/tests/unit/net_test.ts b/cli/tests/unit/net_test.ts
index e970f0360..793082ced 100644
--- a/cli/tests/unit/net_test.ts
+++ b/cli/tests/unit/net_test.ts
@@ -34,7 +34,7 @@ unitTest(
assertEquals(socket.addr.hostname, "127.0.0.1");
assertEquals(socket.addr.port, 3500);
socket.close();
- }
+ },
);
unitTest(
@@ -48,7 +48,7 @@ unitTest(
assert(socket.addr.transport === "unix");
assertEquals(socket.addr.path, filePath);
socket.close();
- }
+ },
);
unitTest(
@@ -62,7 +62,7 @@ unitTest(
assert(socket.addr.transport === "unixpacket");
assertEquals(socket.addr.path, filePath);
socket.close();
- }
+ },
);
unitTest(
@@ -78,9 +78,9 @@ unitTest(
await p;
},
Deno.errors.BadResource,
- "Listener has been closed"
+ "Listener has been closed",
);
- }
+ },
);
unitTest(
@@ -98,9 +98,9 @@ unitTest(
await p;
},
Deno.errors.BadResource,
- "Listener has been closed"
+ "Listener has been closed",
);
- }
+ },
);
unitTest(
@@ -123,7 +123,7 @@ unitTest(
listener.close();
await Promise.all([p, p1]);
assertEquals(acceptErrCount, 1);
- }
+ },
);
// TODO(jsouto): Enable when tokio updates mio to v0.7!
@@ -148,7 +148,7 @@ unitTest(
listener.close();
await [p, p1];
assertEquals(acceptErrCount, 1);
- }
+ },
);
unitTest({ perms: { net: true } }, async function netTcpDialListen(): Promise<
@@ -163,7 +163,7 @@ unitTest({ perms: { net: true } }, async function netTcpDialListen(): Promise<
assertEquals(conn.localAddr.port, 3500);
await conn.write(new Uint8Array([1, 2, 3]));
conn.close();
- }
+ },
);
const conn = await Deno.connect({ hostname: "127.0.0.1", port: 3500 });
@@ -200,7 +200,7 @@ unitTest(
assertEquals(conn.localAddr.path, filePath);
await conn.write(new Uint8Array([1, 2, 3]));
conn.close();
- }
+ },
);
const conn = await Deno.connect({ path: filePath, transport: "unix" });
assert(conn.remoteAddr.transport === "unix");
@@ -221,7 +221,7 @@ unitTest(
listener.close();
conn.close();
- }
+ },
);
unitTest(
@@ -251,7 +251,7 @@ unitTest(
assertEquals(3, recvd[2]);
alice.close();
bob.close();
- }
+ },
);
unitTest(
@@ -266,7 +266,7 @@ unitTest(
const b = socket.send(new Uint8Array(), socket.addr);
await Promise.all([a, b]);
socket.close();
- }
+ },
);
unitTest(
@@ -300,7 +300,7 @@ unitTest(
assertEquals(3, recvd[2]);
alice.close();
bob.close();
- }
+ },
);
unitTest(
@@ -336,7 +336,7 @@ unitTest(
conn2.close();
await promise;
- }
+ },
);
unitTest(
@@ -349,7 +349,7 @@ unitTest(
const nextAfterClosing = listener[Symbol.asyncIterator]().next();
assertEquals(await nextAfterClosing, { value: undefined, done: true });
- }
+ },
);
unitTest(
@@ -362,7 +362,7 @@ unitTest(
const nextAfterClosing = socket[Symbol.asyncIterator]().next();
assertEquals(await nextAfterClosing, { value: undefined, done: true });
- }
+ },
);
unitTest(
@@ -376,7 +376,7 @@ unitTest(
const nextAfterClosing = socket[Symbol.asyncIterator]().next();
assertEquals(await nextAfterClosing, { value: undefined, done: true });
- }
+ },
);
unitTest(
@@ -393,7 +393,7 @@ unitTest(
const nextAfterClosing = socket[Symbol.asyncIterator]().next();
assertEquals(await nextAfterClosing, { value: undefined, done: true });
- }
+ },
);
unitTest(
@@ -428,7 +428,7 @@ unitTest(
listener.close();
conn.close();
- }
+ },
);
unitTest(
@@ -462,7 +462,7 @@ unitTest(
closeDeferred.resolve();
listener.close();
conn.close();
- }
+ },
);
unitTest(
@@ -488,7 +488,7 @@ unitTest(
closeDeferred.resolve();
listener.close();
conn.close();
- }
+ },
);
unitTest(
@@ -531,5 +531,5 @@ unitTest(
acceptedConn!.close();
listener.close();
await resolvable;
- }
+ },
);