| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -43,4 +43,5 @@ async function checkClient() { | |||
| 43 | 43 | } | |
| 44 | 44 | ||
| 45 | 45 | await Promise.all([serverOpened.promise, checkClient()]); | |
| 46 | - clientSession.close(); | ||
| 46 | + await clientSession.close(); | ||
| 47 | + await serverEndpoint.close(); | ||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -52,3 +52,4 @@ await rejects(clientSession.opened, expected); | |||
| 52 | 52 | // The handshake should fail — opened may reject or never resolve. | |
| 53 | 53 | // The session should close with an error. | |
| 54 | 54 | await rejects(clientSession.closed, expected); | |
| 55 | + await serverEndpoint.close(); | ||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -45,3 +45,4 @@ const clientSession = await connect(serverEndpoint.address, { | |||
| 45 | 45 | ||
| 46 | 46 | await Promise.all([serverOpened.promise, checkSession(clientSession)]); | |
| 47 | 47 | await clientSession.close(); | |
| 48 | + await serverEndpoint.close(); | ||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -43,3 +43,4 @@ stream.setBody(new Uint8Array(4096)); | |||
| 43 | 43 | ||
| 44 | 44 | // The stream's closed promise should reject with the error from the throw. | |
| 45 | 45 | await rejects(stream.closed, testError); | |
| 46 | + await serverEndpoint.close(); | ||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -39,5 +39,4 @@ await clientSession.sendDatagram(new Uint8Array([1, 2, 3])); | |||
| 39 | 39 | ||
| 40 | 40 | await serverDone.promise; | |
| 41 | 41 | await clientSession.closed; | |
| 42 | - serverEndpoint.close(); | ||
| 43 | - await serverEndpoint.closed; | ||
| 42 | + await serverEndpoint.close(); | ||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -38,3 +38,4 @@ await clientSession.sendDatagram(new Uint8Array([1, 2, 3])); | |||
| 38 | 38 | ||
| 39 | 39 | // The session's closed should reject with the error from the throw. | |
| 40 | 40 | await rejects(clientSession.closed, testError); | |
| 41 | + await serverEndpoint.close(); | ||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -34,3 +34,4 @@ await clientSession.opened; | |||
| 34 | 34 | clientSession.destroy(testError); | |
| 35 | 35 | ||
| 36 | 36 | await rejects(clientSession.closed, testError); | |
| 37 | + await serverEndpoint.close(); | ||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -60,3 +60,4 @@ stream.onerror = undefined; | |||
| 60 | 60 | strictEqual(stream.onerror, undefined); | |
| 61 | 61 | ||
| 62 | 62 | await clientSession.closed; | |
| 63 | + await serverEndpoint.close(); | ||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -72,5 +72,4 @@ const serverEndpoint = await listen(mustCall(async (serverSession) => { | |||
| 72 | 72 | await clientSession.closed; | |
| 73 | 73 | } | |
| 74 | 74 | ||
| 75 | - serverEndpoint.close(); | ||
| 76 | - await serverEndpoint.closed; | ||
| 75 | + await serverEndpoint.close(); | ||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -50,3 +50,4 @@ clientSession.destroy(originalError); | |||
| 50 | 50 | ||
| 51 | 51 | // Closed rejects with the original error (not the SuppressedError). | |
| 52 | 52 | await rejects(clientSession.closed, originalError); | |
| 53 | + await serverEndpoint.close(); | ||
| Back | FazBrowse Home | New Git URL |
0 commit comments