aboutsummaryrefslogtreecommitdiff
path: root/packages/taler-wallet-core/src/util/promiseUtils.ts
diff options
context:
space:
mode:
authorÖzgür Kesim <oec-taler@kesim.org>2023-08-25 13:24:08 +0200
committerÖzgür Kesim <oec-taler@kesim.org>2023-08-25 13:24:08 +0200
commit5ab3070b3a63c2e8fed0e413dea06cf03fb48f1e (patch)
tree121425d99c9465f2daf8ac91c6dc2254ebac5906 /packages/taler-wallet-core/src/util/promiseUtils.ts
parent70fca92e781696a057089bc8bc48adebdf6e017e (diff)
parent2051aded501cddac1a4c869fb1f9731ac4523a1e (diff)
Merge branch 'master' into age-withdraw
Diffstat (limited to 'packages/taler-wallet-core/src/util/promiseUtils.ts')
-rw-r--r--packages/taler-wallet-core/src/util/promiseUtils.ts24
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;
}
}