Class ControlledSource

src/monitoring.spec.ts:516–536

});

class ControlledSource implements MachineStatsSource {
  public readonly name = 'controlled';
  protected values: Array<{ cpu: number | null; memory: number | null }> = [];
  protected callCount = 0;

  public setSequence(
    values: Array<{ cpu: number | null; memory: number | null }>,
  ) {
    this.values = values;
    this.callCount = 0;
  }

  public async read(): Promise<IResourceLoad> {
    const i = this.callCount;
    this.callCount++;
    if (this.values.length === 0) {
      return { cpu: 0, memory: 0 };
    }
    return this.values[Math.min(i, this.values.length - 1)];
  }
}

class TestMonitoring extends Monitoring {
  public async runSample(): Promise<void> {