Method initWorker

src/ProcessFork.ts:56–93

()

    return clone;
  }
  private initWorker() {
    this.childProcess.on("exit",()=>{
      this.flushResult();
    })
    this.childProcess.send({
      cmd: "init",
      params: this.prepareParam(this.converter.parseParam)
    } as InitMessage);
    this.childProcess.on("message", (msg: Message) => {
      if (msg.cmd === "inited") {
        this.inited = true;
      } else if (msg.cmd === "eol") {
        if (this.converter.listeners("eol").length > 0){
          this.converter.emit("eol",(msg as StringMessage).value);
        }
      }else if (msg.cmd === "header") {
        if (this.converter.listeners("header").length > 0){
          this.converter.emit("header",(msg as StringMessage).value);
        }
      }else if (msg.cmd === "done"){

        // this.flushResult();
      }

    });
    this.childProcess.stdout?.on("data", (data) => {
      // console.log("stdout", data.toString());
      const res = data.toString();
      // console.log(res);
      this.appendBuf(res);

    });
    this.childProcess.stderr?.on("data", (data) => {
      // console.log("stderr", data.toString());
      this.converter.emit("error", CSVError.fromJSON(JSON.parse(data.toString())));
    });

  }
  private flushResult() {
    // console.log("flush result", this.resultBuf.length);
    if (this.next) {