Method flush

src/ProcessFork.ts:11–22

()

export class ProcessorFork extends Processor {
  flush(): Promise<ProcessLineResult[]> {
    return new Promise((resolve, reject) => {
      // console.log("flush");
      this.finalChunk = true;
      this.next = resolve;
      this.childProcess.stdin?.end();
      // this.childProcess.stdout.on("end",()=>{
      //   // console.log("!!!!");
      //   this.flushResult();
      // })
    });
  }
  destroy(): Promise<void> {
    this.childProcess.kill();
    return Promise.resolve();