32 lines
911 B
TypeScript
32 lines
911 B
TypeScript
|
import { IAsyncQueue } from "../models/spt/utils/IAsyncQueue";
|
||
|
|
import { ICommand } from "../models/spt/utils/ICommand";
|
||
|
|
|
||
|
|
export class AsyncQueue implements IAsyncQueue
|
||
|
|
{
|
||
|
|
protected commandsQueue: ICommand[]
|
||
|
|
|
||
|
|
constructor()
|
||
|
|
{
|
||
|
|
this.commandsQueue = [];
|
||
|
|
}
|
||
|
|
|
||
|
|
// Wait for the right command to execute
|
||
|
|
// This ensures that the commands execute in the right order, thus no data corruption
|
||
|
|
public async waitFor(command: ICommand): Promise<any>
|
||
|
|
{
|
||
|
|
// Add to the queue
|
||
|
|
this.commandsQueue.push(command);
|
||
|
|
|
||
|
|
// eslint-disable-next-line no-constant-condition
|
||
|
|
while (this.commandsQueue[0].uuid !== command.uuid)
|
||
|
|
{
|
||
|
|
await new Promise<void>(resolve =>
|
||
|
|
{
|
||
|
|
setTimeout(resolve, 100);
|
||
|
|
})
|
||
|
|
}
|
||
|
|
|
||
|
|
// When the command is ready, execute it
|
||
|
|
return this.commandsQueue.shift().cmd();
|
||
|
|
}
|
||
|
|
}
|