diff options
Diffstat (limited to 'cli/tests/unit/net_test.ts')
-rw-r--r-- | cli/tests/unit/net_test.ts | 48 |
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; - } + }, ); |