Method flush

src/ProcessorLocal.ts:14–29

()

export class ProcessorLocal extends Processor {
  flush(): Promise<ProcessLineResult[]> {
    if (this.runtime.csvLineBuffer && this.runtime.csvLineBuffer.length > 0) {
      const buf = this.runtime.csvLineBuffer;
      this.runtime.csvLineBuffer = undefined;
      return this.process(buf, true)
        .then((res) => {
          if (this.runtime.csvLineBuffer && this.runtime.csvLineBuffer.length > 0) {
            return Promise.reject(CSVError.unclosed_quote(this.runtime.parsedLineNumber, this.runtime.csvLineBuffer.toString()))
          } else {
            return Promise.resolve(res);
          }
        })
    } else {
      return Promise.resolve([]);
    }
  }
  destroy(): Promise<void> {
    return Promise.resolve();
  }