OpenServer/Utils
1
0
Fork 0
Code Issues Pull Requests 1 Releases Wiki Activity

Fixing some bug

Browse Source
This commit is contained in:
Fabian Stamm
2019-11-26 22:06:27 +01:00
parent 0781323acb
commit 6720432e24
2 changed files with 11 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/awaiter.ts
View File

@ -28,7 +28,7 @@ export default class AwaitStore<T = any> {
awaitValue(val: T): PromiseLike<void> & { catch: (cb: (err: any) => PromiseLike<void>) => PromiseLike<void>, ignore: () => void } {
let ignore: () => void;
let ignore: () => void = () => undefined;
let prms = new Promise<void>(yes => {
const cb = () => {
@ -41,12 +41,15 @@ export default class AwaitStore<T = any> {
return false
}
ignore = () => {
this.observable.unsubscribe(cb);
}
if (!cb()) {
this.observable.subscribe(cb);
if (this._value === val) {
yes();
} else {
ignore = () => {
this.observable.unsubscribe(cb);
}
if (!cb()) {
this.observable.subscribe(cb);
}
}
});