3
0
Fork 0
mirror of https://github.com/ZeppelinBot/Zeppelin.git synced 2025-05-24 10:05:03 +00:00

Ugly workaround/hotfix for message fetching

This commit is contained in:
Dragory 2021-08-19 00:49:06 +03:00
parent 0f5072425a
commit 030c3afb63
9 changed files with 31 additions and 14 deletions

View file

@ -28,11 +28,11 @@ export class Queue<TQueueFunction extends AnyFn = AnyFn> {
return this.queue.length + (this.running ? 1 : 0);
}
public add(fn: TQueueFunction): Promise<void> {
const promise = new Promise<void>(resolve => {
public add(fn: TQueueFunction): Promise<any> {
const promise = new Promise<any>(resolve => {
this.queue.push(async () => {
await fn();
resolve();
const result = await fn();
resolve(result);
});
if (!this.running) this.next();