summaryrefslogtreecommitdiff
path: root/cli/tests/unit_node/_fs
diff options
context:
space:
mode:
Diffstat (limited to 'cli/tests/unit_node/_fs')
-rw-r--r--cli/tests/unit_node/_fs/_fs_read_test.ts21
1 files changed, 10 insertions, 11 deletions
diff --git a/cli/tests/unit_node/_fs/_fs_read_test.ts b/cli/tests/unit_node/_fs/_fs_read_test.ts
index 34b029d9f..3ca303037 100644
--- a/cli/tests/unit_node/_fs/_fs_read_test.ts
+++ b/cli/tests/unit_node/_fs/_fs_read_test.ts
@@ -10,7 +10,6 @@ import { open, openSync } from "node:fs";
import { Buffer } from "node:buffer";
import * as path from "../../../../test_util/std/path/mod.ts";
import { closeSync } from "node:fs";
-import { deferred } from "../../../../test_util/std/async/deferred.ts";
async function readTest(
testData: string,
@@ -132,7 +131,7 @@ Deno.test({
Deno.test({
name: "[std/node/fs] Read fs.read(fd, options, cb) signature",
async fn() {
- const promise = deferred();
+ const { promise, reject, resolve } = Promise.withResolvers<void>();
const file = Deno.makeTempFileSync();
Deno.writeTextFileSync(file, "hi there");
const fd = openSync(file, "r+");
@@ -154,10 +153,10 @@ Deno.test({
Buffer.from([104, 105, 32, 116, 104, 101, 114, 101, 0, 0, 0]),
);
} catch (e) {
- promise.reject(e);
+ reject(e);
return;
}
- promise.resolve();
+ resolve();
},
);
closeSync(fd);
@@ -168,7 +167,7 @@ Deno.test({
Deno.test({
name: "[std/node/fs] Read fs.read(fd, cb) signature",
async fn() {
- const promise = deferred();
+ const { promise, resolve, reject } = Promise.withResolvers<void>();
const file = Deno.makeTempFileSync();
Deno.writeTextFileSync(file, "hi deno");
const fd = openSync(file, "r+");
@@ -178,10 +177,10 @@ Deno.test({
assertStrictEquals(bytesRead, 7);
assertStrictEquals(data?.byteLength, 16384);
} catch (e) {
- promise.reject(e);
+ reject(e);
return;
}
- promise.resolve();
+ resolve();
});
closeSync(fd);
await promise;
@@ -277,27 +276,27 @@ Deno.test({
await Deno.writeTextFile(file, "abc");
await t.step("without position option", async () => {
- const promise = deferred<void>();
+ const { promise, resolve } = Promise.withResolvers<void>();
let called = false;
const fd = openSync(file, "r");
read(fd, () => {
called = true;
closeSync(fd);
- promise.resolve();
+ resolve();
});
assertFalse(called);
await promise;
});
await t.step("with position option", async () => {
- const promise = deferred<void>();
+ const { promise, resolve } = Promise.withResolvers<void>();
let called = false;
const buffer = Buffer.alloc(2);
const fd = openSync(file, "r");
read(fd, { position: 1, buffer, offset: 0, length: 2 }, () => {
called = true;
closeSync(fd);
- promise.resolve();
+ resolve();
});
assertFalse(called);
await promise;