diff options
author | Florian Dold <florian@dold.me> | 2023-08-22 08:54:28 +0200 |
---|---|---|
committer | Florian Dold <florian@dold.me> | 2023-08-22 08:54:28 +0200 |
commit | 8c670bd06d62bb82f714f4ca8a8730b2abacc013 (patch) | |
tree | b09845e997a8d79ec2f65fe668a164746d636c78 /packages/taler-wallet-core | |
parent | f9d1c4a89e2a686f0c82f8dc63ab3f1008763759 (diff) | |
download | wallet-core-8c670bd06d62bb82f714f4ca8a8730b2abacc013.tar.xz |
wallet-core: simplify/optimize async condition
Diffstat (limited to 'packages/taler-wallet-core')
-rw-r--r-- | packages/taler-wallet-core/src/util/promiseUtils.ts | 24 |
1 files changed, 12 insertions, 12 deletions
diff --git a/packages/taler-wallet-core/src/util/promiseUtils.ts b/packages/taler-wallet-core/src/util/promiseUtils.ts index d409686d9..23f1c06a5 100644 --- a/packages/taler-wallet-core/src/util/promiseUtils.ts +++ b/packages/taler-wallet-core/src/util/promiseUtils.ts @@ -23,6 +23,8 @@ export interface OpenedPromise<T> { /** * Get an unresolved promise together with its extracted resolve / reject * function. + * + * Recent ECMAScript proposals also call this a promise capability. */ export function openPromise<T>(): OpenedPromise<T> { let resolve: ((x?: any) => void) | null = null; @@ -39,22 +41,20 @@ export function openPromise<T>(): OpenedPromise<T> { } export class AsyncCondition { - private _waitPromise: Promise<void>; - private _resolveWaitPromise: (val: void) => void; - constructor() { - const op = openPromise<void>(); - this._waitPromise = op.promise; - this._resolveWaitPromise = op.resolve; - } + private promCap?: OpenedPromise<void> = undefined; + constructor() {} wait(): Promise<void> { - return this._waitPromise; + if (!this.promCap) { + this.promCap = openPromise<void>(); + } + return this.promCap.promise; } trigger(): void { - this._resolveWaitPromise(); - const op = openPromise<void>(); - this._waitPromise = op.promise; - this._resolveWaitPromise = op.resolve; + if (this.promCap) { + this.promCap.resolve(); + } + this.promCap = undefined; } } |