*/
export class LimitedQueue {
private readonly sequentializer = new TaskSequentializer();
private tasks = 0;
queue(factory: ITask<Promise<void>>): Promise<void> {
return this.sequentializer.run(this.tasks++, factory());
}
return this.sequentializer.queue(() => {
return this.sequentializer.run(this.tasks++, factory());
});
}
}