Akxe

/// <reference lib="webworker" />

type SharedWorkerPort = MessagePort | DedicatedWorkerGlobalScope;
class PortAwareSharedWorkerPort<T extends SharedWorkerPort = SharedWorkerPort, D = any> {
	private readonly weakRef: WeakRef<T>;
	private disconnected = false;

	constructor(
		port: T,
		onMessage: (eventData: D) => void,