Thread.ts

export class Thread<RT> {
  private _worker: Worker;
  private _listeners: (data: RT[]) => void;

  constructor(lambda: (this: Worker) => void) {
    const textContent = lambda.toString().replace(/^function .+\{?|\}$/g, "");
    const blob = new Blob([textContent], { type: "application/java-script" });

    this._worker = new Worker(URL.createObjectURL(blob));
    this._worker.addEventListener("message", this._loger);
  }

  private _loger = (e: MessageEvent) => {
    console.info("Threaded message: ", e.data);
  };
}