mirror of
https://github.com/denoland/deno.git
synced 2024-12-22 07:14:47 -05:00
49e3ee010c
This commit adds: - `addAbortListener` in `node:events` - `aborted` in `node:util` - `execPath` and `execvArgs` named export from `node:process` - `getDefaultHighWaterMark` from `node:stream` The `execPath` is very hacky - because module namespaces can not have real getters, `execPath` is an object with a `toString()` method that on call returns the actual `execPath`, and replaces the `execPath` binding with the string. This is done so that we don't require the `execPath` permission on startup.
47 lines
1.1 KiB
TypeScript
47 lines
1.1 KiB
TypeScript
// Copyright 2018-2024 the Deno authors. All rights reserved. MIT license.
|
|
|
|
// @ts-expect-error: @types/node is outdated
|
|
import events, { addAbortListener, EventEmitter } from "node:events";
|
|
|
|
EventEmitter.captureRejections = true;
|
|
|
|
Deno.test("regression #20441", async () => {
|
|
const { promise, resolve } = Promise.withResolvers<void>();
|
|
|
|
const ee = new EventEmitter();
|
|
|
|
ee.on("foo", function () {
|
|
const p = new Promise((_resolve, reject) => {
|
|
setTimeout(() => {
|
|
reject();
|
|
}, 100);
|
|
});
|
|
return p;
|
|
});
|
|
|
|
ee.on("error", function (_) {
|
|
resolve();
|
|
});
|
|
|
|
ee.emit("foo");
|
|
await promise;
|
|
});
|
|
|
|
Deno.test("eventemitter async resource", () => {
|
|
// @ts-ignore: @types/node is outdated
|
|
class Foo extends events.EventEmitterAsyncResource {}
|
|
|
|
const foo = new Foo();
|
|
// @ts-ignore: @types/node is outdated
|
|
foo.emit("bar");
|
|
});
|
|
|
|
Deno.test("addAbortListener", async () => {
|
|
const { promise, resolve } = Promise.withResolvers<void>();
|
|
const abortController = new AbortController();
|
|
addAbortListener(abortController.signal, () => {
|
|
resolve();
|
|
});
|
|
abortController.abort();
|
|
await promise;
|
|
});
|