mirror of
https://github.com/immich-app/immich.git
synced 2026-05-18 03:10:24 +03:00
clarify resolution loop
This commit is contained in:
@@ -28,10 +28,13 @@ export class PendingEvents<T extends { [T in EmitEvent]: ArgOf<T> extends { erro
|
|||||||
}
|
}
|
||||||
clearTimeout(pending.timeout);
|
clearTimeout(pending.timeout);
|
||||||
this.pending.delete(key);
|
this.pending.delete(key);
|
||||||
for (const completer of pending.completers) {
|
if ('error' in value) {
|
||||||
if ('error' in value) {
|
const error = new Error(value.error);
|
||||||
completer.reject(new Error(value.error));
|
for (const completer of pending.completers) {
|
||||||
} else {
|
completer.reject(error);
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
for (const completer of pending.completers) {
|
||||||
completer.resolve(value);
|
completer.resolve(value);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user