r = @getInternalField(@internalModuleRegistry, 95) || @createInternalModuleById(95), Readable = @getInternalField(@internalModuleRegistry, 55) || @createInternalModuleById(55), { throwNotImplemented, warnNotImplementedOnce } = @getInternalField(@internalModuleRegistry, 32) || @createInternalModuleById(32), {
  MessageChannel,
  BroadcastChannel,
  Worker: WebWorker
} = globalThis, SHARE_ENV = Symbol("nodejs.worker_threads.SHARE_ENV"), isMainThread = Bun.isMainThread, {
  0: _workerData,
  1: _threadId,
  2: _receiveMessageOnPort,
  3: environmentData
} = @lazy(86), urlRevokeRegistry = @undefined;
function injectFakeEmitter(Class) {
  function messageEventHandler(event) {
    return event.data;
  }
  function errorEventHandler(event) {
    return event.error;
  }
  let wrappedListener = Symbol("wrappedListener");
  function wrapped(run, listener) {
    let callback = function(event) {
      return listener(run(event));
    };
    return listener[wrappedListener] = callback, callback;
  }
  function functionForEventType(event, listener) {
    switch (event) {
      case "error":
      case "messageerror":
        return wrapped(errorEventHandler, listener);
      default:
        return wrapped(messageEventHandler, listener);
    }
  }
  Class.prototype.on = function(event, listener) {
    return this.addEventListener(event, functionForEventType(event, listener)), this;
  }, Class.prototype.off = function(event, listener) {
    if (listener)
      this.removeEventListener(event, listener[wrappedListener] || listener);
    else
      this.removeEventListener(event);
    return this;
  }, Class.prototype.once = function(event, listener) {
    return this.addEventListener(event, functionForEventType(event, listener), { once: !0 }), this;
  };
  function EventClass(eventName) {
    if (eventName === "error" || eventName === "messageerror")
      return ErrorEvent;
    return MessageEvent;
  }
  Class.prototype.emit = function(event, ...args) {
    return this.dispatchEvent(new (EventClass(event))(event, ...args)), this;
  }, Class.prototype.prependListener = Class.prototype.on, Class.prototype.prependOnceListener = Class.prototype.once;
}
var _MessagePort = globalThis.MessagePort;
injectFakeEmitter(_MessagePort);
var MessagePort = _MessagePort, resourceLimits = {}, workerData = _workerData, threadId = _threadId;
function receiveMessageOnPort(port) {
  let res = _receiveMessageOnPort(port);
  if (!res)
    return @undefined;
  return {
    message: res
  };
}
function fakeParentPort() {
  let fake = Object.create(MessagePort.prototype);
  Object.defineProperty(fake, "onmessage", {
    get() {
      return self.onmessage;
    },
    set(value) {
      self.onmessage = value;
    }
  }), Object.defineProperty(fake, "onmessageerror", {
    get() {
      return self.onmessageerror;
    },
    set(value) {
      self.onmessageerror = value;
    }
  });
  let postMessage = @lazy(87);
  return Object.defineProperty(fake, "postMessage", {
    value(...args) {
      return postMessage.@apply(null, args);
    }
  }), Object.defineProperty(fake, "close", {
    value() {
    }
  }), Object.defineProperty(fake, "start", {
    value() {
    }
  }), Object.defineProperty(fake, "unref", {
    value() {
    }
  }), Object.defineProperty(fake, "ref", {
    value() {
    }
  }), Object.defineProperty(fake, "hasRef", {
    value() {
      return !1;
    }
  }), Object.defineProperty(fake, "setEncoding", {
    value() {
    }
  }), Object.defineProperty(fake, "addEventListener", {
    value: self.addEventListener.bind(self)
  }), Object.defineProperty(fake, "removeEventListener", {
    value: self.removeEventListener.bind(self)
  }), Object.defineProperty(fake, "removeListener", {
    value: self.removeEventListener.bind(self),
    enumerable: !1
  }), Object.defineProperty(fake, "addListener", {
    value: self.addEventListener.bind(self),
    enumerable: !1
  }), fake;
}
var parentPort = isMainThread ? null : fakeParentPort();
function getEnvironmentData(key) {
  return environmentData.get(key);
}
function setEnvironmentData(key, value) {
  if (value === @undefined)
    environmentData.delete(key);
  else
    environmentData.set(key, value);
}
function markAsUntransferable() {
  throwNotImplemented("worker_threads.markAsUntransferable");
}
function moveMessagePortToContext() {
  throwNotImplemented("worker_threads.moveMessagePortToContext");
}

class Worker extends EventEmitter {
  #worker;
  #performance;
  #onExitPromise = @undefined;
  #urlToRevoke = "";
  constructor(filename, options = {}) {
    super();
    let builtinsGeneratorHatesEval = "eval";
    if (options && builtinsGeneratorHatesEval in options)
      if (options[builtinsGeneratorHatesEval]) {
        let blob = new Blob([filename], { type: "" });
        this.#urlToRevoke = filename = URL.createObjectURL(blob);
      } else
        this.#urlToRevoke = filename;
    try {
      this.#worker = new WebWorker(filename, options, this);
    } catch (e) {
      if (this.#urlToRevoke)
        URL.revokeObjectURL(this.#urlToRevoke);
      throw e;
    }
    if (this.#worker.addEventListener("close", this.#onClose.bind(this), { once: !0 }), this.#worker.addEventListener("error", this.#onError.bind(this)), this.#worker.addEventListener("message", this.#onMessage.bind(this)), this.#worker.addEventListener("messageerror", this.#onMessageError.bind(this)), this.#worker.addEventListener("open", this.#onOpen.bind(this), { once: !0 }), this.#urlToRevoke) {
      if (!urlRevokeRegistry)
        urlRevokeRegistry = new FinalizationRegistry((url) => {
          URL.revokeObjectURL(url);
        });
      urlRevokeRegistry.register(this.#worker, this.#urlToRevoke);
    }
  }
  get threadId() {
    return this.#worker.threadId;
  }
  ref() {
    this.#worker.ref();
  }
  unref() {
    this.#worker.unref();
  }
  get stdin() {
    return null;
  }
  get stdout() {
    return null;
  }
  get stderr() {
    return null;
  }
  get performance() {
    return this.#performance ??= {
      eventLoopUtilization() {
        return warnNotImplementedOnce("worker_threads.Worker.performance"), {
          idle: 0,
          active: 0,
          utilization: 0
        };
      }
    };
  }
  terminate(callback) {
    if (typeof callback === "function")
      process.emitWarning("Passing a callback to worker.terminate() is deprecated. It returns a Promise instead.", "DeprecationWarning", "DEP0132"), this.#worker.addEventListener("close", (event) => callback(null, event.code), { once: !0 });
    let onExitPromise = this.#onExitPromise;
    if (onExitPromise)
      return @isPromise(onExitPromise) ? onExitPromise : @Promise.@resolve(onExitPromise);
    let { resolve, promise } = @Promise.withResolvers();
    return this.#worker.addEventListener("close", (event) => {
      resolve(event.code);
    }, { once: !0 }), this.#worker.terminate(), this.#onExitPromise = promise;
  }
  postMessage(...args) {
    return this.#worker.postMessage.@apply(this.#worker, args);
  }
  getHeapSnapshot(options) {
    return this.#worker.getHeapSnapshot(options).then((s) => new HeapSnapshotStream(s));
  }
  #onClose(e) {
    this.#onExitPromise = e.code, this.emit("exit", e.code);
  }
  #onError(event) {
    let error = event?.error;
    if (event.message !== "") {
      error = new Error(event.message, { cause: event });
      let stack = event?.stack;
      if (stack)
        error.stack = stack;
    }
    this.emit("error", error);
  }
  #onMessage(event) {
    this.emit("message", event.data);
  }
  #onMessageError(event) {
    this.emit("messageerror", event.error ?? event.data ?? event);
  }
  #onOpen() {
    this.emit("online");
  }
  async[Symbol.asyncDispose]() {
    await this.terminate();
  }
}

class HeapSnapshotStream extends Readable {
  #json;
  constructor(json) {
    super();
    this.#json = json;
  }
  _read() {
    if (this.#json !== @undefined)
      this.push(this.#json), this.push(null), this.#json = @undefined;
  }
}
$ = {
  Worker,
  workerData,
  parentPort,
  resourceLimits,
  isMainThread,
  MessageChannel,
  BroadcastChannel,
  MessagePort,
  getEnvironmentData,
  setEnvironmentData,
  getHeapSnapshot() {
    return {};
  },
  markAsUntransferable,
  moveMessagePortToContext,
  receiveMessageOnPort,
  SHARE_ENV,
  threadId
};
return $})