37 lines
1.0 KiB
TypeScript
37 lines
1.0 KiB
TypeScript
import * as plugins from './taskbuffer.plugins.js';
|
|
import { Task } from './taskbuffer.classes.task.js';
|
|
|
|
export interface ICycleObject {
|
|
cycleCounter: number;
|
|
deferred: plugins.smartpromise.Deferred<any>;
|
|
}
|
|
|
|
export class CycleCounter {
|
|
public task: Task;
|
|
public cycleObjectArray: ICycleObject[] = [];
|
|
constructor(taskArg: Task<any>) {
|
|
this.task = taskArg;
|
|
}
|
|
public getPromiseForCycle(cycleCountArg: number) {
|
|
const done = plugins.smartpromise.defer();
|
|
const cycleObject: ICycleObject = {
|
|
cycleCounter: cycleCountArg,
|
|
deferred: done,
|
|
};
|
|
this.cycleObjectArray.push(cycleObject);
|
|
return done.promise;
|
|
}
|
|
public informOfCycle(x: any) {
|
|
const newCycleObjectArray: ICycleObject[] = [];
|
|
this.cycleObjectArray.forEach((cycleObjectArg) => {
|
|
cycleObjectArg.cycleCounter--;
|
|
if (cycleObjectArg.cycleCounter <= 0) {
|
|
cycleObjectArg.deferred.resolve(x);
|
|
} else {
|
|
newCycleObjectArray.push(cycleObjectArg);
|
|
}
|
|
});
|
|
this.cycleObjectArray = newCycleObjectArray;
|
|
}
|
|
}
|