Files
bun.sh/src/js/node/domain.ts
Meghan Denny 2d481e7bcb fix more node:stream (#16385)
Co-authored-by: Jarred Sumner <jarred@jarredsumner.com>
2025-01-16 22:40:39 -08:00

78 lines
1.6 KiB
TypeScript

// Import Events
let EventEmitter;
const ObjectDefineProperty = Object.defineProperty;
// Export Domain
var domain: any = {};
domain.createDomain = domain.create = function () {
if (!EventEmitter) {
EventEmitter = require("node:events");
}
var d = new EventEmitter();
function emitError(e) {
e ||= $ERR_UNHANDLED_ERROR();
if (typeof e === "object") {
e.domainEmitter = this;
ObjectDefineProperty(e, "domain", {
__proto__: null,
configurable: true,
enumerable: false,
value: domain,
writable: true,
});
e.domainThrown = false;
}
d.emit("error", e);
}
d.add = function (emitter) {
emitter.on("error", emitError);
};
d.remove = function (emitter) {
emitter.removeListener("error", emitError);
};
d.bind = function (fn) {
return function () {
var args = Array.prototype.slice.$call(arguments);
try {
fn.$apply(null, args);
} catch (err) {
emitError(err);
}
};
};
d.intercept = function (fn) {
return function (err) {
if (err) {
emitError(err);
} else {
var args = Array.prototype.slice.$call(arguments, 1);
try {
fn.$apply(null, args);
} catch (err) {
emitError(err);
}
}
};
};
d.run = function (fn) {
try {
fn();
} catch (err) {
emitError(err);
}
return this;
};
d.dispose = function () {
this.removeAllListeners();
return this;
};
d.enter = d.exit = function () {
return this;
};
return d;
};
export default domain;