diff options
author | Kevin (Kun) "Kassimo" Qian <kevinkassimo@gmail.com> | 2018-10-05 17:09:46 -0700 |
---|---|---|
committer | Ryan Dahl <ry@tinyclouds.org> | 2018-10-05 21:06:01 -0400 |
commit | 3c212ddd1ead9c3414fd4e3481825d2c4c4cc6eb (patch) | |
tree | 48e6127cfeeb5c768b6d060112d15ec33047104a /js | |
parent | 5f14ec486c6a6edf0cee2643b4dbebd5b86cc884 (diff) |
Remove race condition from netCloseReadSuccess test
Diffstat (limited to 'js')
-rw-r--r-- | js/net_test.ts | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/js/net_test.ts b/js/net_test.ts index c7c8dbb59..95f901a62 100644 --- a/js/net_test.ts +++ b/js/net_test.ts @@ -41,7 +41,9 @@ testPerm({ net: true }, async function netCloseReadSuccess() { const addr = "127.0.0.1:4500"; const listener = deno.listen("tcp", addr); const closeDeferred = deferred(); + const closeReadDeferred = deferred(); listener.accept().then(async conn => { + await closeReadDeferred.promise; await conn.write(new Uint8Array([1, 2, 3])); const buf = new Uint8Array(1024); const readResult = await conn.read(buf); @@ -54,6 +56,7 @@ testPerm({ net: true }, async function netCloseReadSuccess() { }); const conn = await deno.dial("tcp", addr); conn.closeRead(); // closing read + closeReadDeferred.resolve(); const buf = new Uint8Array(1024); const readResult = await conn.read(buf); assertEqual(0, readResult.nread); // No error, read nothing |