taskbuffer/ts/taskbuffer.classes.bufferrunner.ts

import { Task } from './taskbuffer.classes.task';

export class BufferRunner {
  public task: Task;
  // initialze by default
  public bufferCounter: number = 0;
  constructor(taskArg: Task) {
    this.task = taskArg;
  }

  public trigger(x: any): Promise<any> {
    if (!(this.bufferCounter >= this.task.bufferMax)) {
      this.bufferCounter++;
    }
    const returnPromise: Promise<any> = this.task.cycleCounter.getPromiseForCycle(
      this.bufferCounter + 1
    );
    if (!this.task.running) {
      this._run(x);
    }
    return returnPromise;
  }

  private _run(x: any) {
    const recursiveBufferRunner = (x: any) => {
      if (this.bufferCounter >= 0) {
        this.task.running = true;
        Task.runTask(this.task, { x: x }).then((x) => {
          this.bufferCounter--; // this.bufferCounter drops below 0, the recursion stops.
          this.task.cycleCounter.informOfCycle(x);
          recursiveBufferRunner(x);
        });
      } else {
        this.task.running = false;
      }
    };
    recursiveBufferRunner(x);
  }
}