summaryrefslogtreecommitdiff
path: root/cli/tests/unit_node/http2_test.ts
diff options
context:
space:
mode:
Diffstat (limited to 'cli/tests/unit_node/http2_test.ts')
-rw-r--r--cli/tests/unit_node/http2_test.ts25
1 files changed, 11 insertions, 14 deletions
diff --git a/cli/tests/unit_node/http2_test.ts b/cli/tests/unit_node/http2_test.ts
index d0e0de43f..87ad6c748 100644
--- a/cli/tests/unit_node/http2_test.ts
+++ b/cli/tests/unit_node/http2_test.ts
@@ -2,7 +2,6 @@
import * as http2 from "node:http2";
import * as net from "node:net";
-import { deferred } from "../../../test_util/std/async/deferred.ts";
import { assertEquals } from "../../../test_util/std/testing/asserts.ts";
for (const url of ["http://127.0.0.1:4246", "https://127.0.0.1:4247"]) {
@@ -41,17 +40,17 @@ for (const url of ["http://127.0.0.1:4246", "https://127.0.0.1:4247"]) {
});
req.end();
- const endPromise = deferred();
+ const { promise, resolve } = Promise.withResolvers<void>();
setTimeout(() => {
try {
client.close();
} catch (_) {
// pass
}
- endPromise.resolve();
+ resolve();
}, 2000);
- await endPromise;
+ await promise;
assertEquals(receivedHeaders, { ":status": 200 });
assertEquals(receivedData, "hello world\n");
@@ -67,14 +66,14 @@ Deno.test(`[node/http2 client createConnection]`, {
ignore: Deno.build.os === "windows",
}, async () => {
const url = "http://127.0.0.1:4246";
- const createConnPromise = deferred();
+ const createConnDeferred = Promise.withResolvers<void>();
// Create a server to respond to the HTTP2 requests
const client = http2.connect(url, {
createConnection() {
const socket = net.connect({ host: "127.0.0.1", port: 4246 });
socket.on("connect", () => {
- createConnPromise.resolve();
+ createConnDeferred.resolve();
});
return socket;
@@ -94,7 +93,7 @@ Deno.test(`[node/http2 client createConnection]`, {
});
req.end();
- const endPromise = deferred();
+ const endPromise = Promise.withResolvers<void>();
setTimeout(() => {
try {
client.close();
@@ -104,8 +103,8 @@ Deno.test(`[node/http2 client createConnection]`, {
endPromise.resolve();
}, 2000);
- await createConnPromise;
- await endPromise;
+ await createConnDeferred.promise;
+ await endPromise.promise;
assertEquals(receivedData, "hello world\n");
});
@@ -127,11 +126,9 @@ Deno.test("[node/http2 server]", { sanitizeOps: false }, async () => {
const stream = await new Promise<http2.ServerHttp2Stream>((resolve) =>
session.on("stream", resolve)
);
- const _headers = await new Promise((resolve) =>
- stream.on("headers", resolve)
- );
- const _data = await new Promise((resolve) => stream.on("data", resolve));
- const _end = await new Promise((resolve) => stream.on("end", resolve));
+ await new Promise((resolve) => stream.on("headers", resolve));
+ await new Promise((resolve) => stream.on("data", resolve));
+ await new Promise((resolve) => stream.on("end", resolve));
stream.respond();
stream.end();
const resp = await responsePromise;