diff options
Diffstat (limited to 'packages/taler-wallet-core/src/observable-wrappers.ts')
-rw-r--r-- | packages/taler-wallet-core/src/observable-wrappers.ts | 15 |
1 files changed, 9 insertions, 6 deletions
diff --git a/packages/taler-wallet-core/src/observable-wrappers.ts b/packages/taler-wallet-core/src/observable-wrappers.ts index b36f41611..7cd65f38e 100644 --- a/packages/taler-wallet-core/src/observable-wrappers.ts +++ b/packages/taler-wallet-core/src/observable-wrappers.ts @@ -25,7 +25,6 @@ import { IDBDatabase } from "@gnu-taler/idb-bridge"; import { ObservabilityContext, ObservabilityEventType, - RetryLoopOpts, } from "@gnu-taler/taler-util"; import { TaskIdStr } from "./common.js"; import { TalerCryptoInterface } from "./index.js"; @@ -65,13 +64,14 @@ export class ObservableTaskScheduler implements TaskScheduler { return this.impl.getActiveTasks(); } - ensureRunning(): void { - return this.impl.ensureRunning(); + isIdle(): boolean { + return this.impl.isIdle(); } - run(opts?: RetryLoopOpts | undefined): Promise<void> { - return this.impl.run(opts); + ensureRunning(): Promise<void> { + return this.impl.ensureRunning(); } + startShepherdTask(taskId: TaskIdStr): void { this.declareDep(taskId); this.oc.observe({ @@ -80,6 +80,7 @@ export class ObservableTaskScheduler implements TaskScheduler { }); return this.impl.startShepherdTask(taskId); } + stopShepherdTask(taskId: TaskIdStr): void { this.declareDep(taskId); this.oc.observe({ @@ -88,6 +89,7 @@ export class ObservableTaskScheduler implements TaskScheduler { }); return this.impl.stopShepherdTask(taskId); } + resetTaskRetries(taskId: TaskIdStr): Promise<void> { this.declareDep(taskId); if (this.taskDepCache.size > 500) { @@ -99,7 +101,8 @@ export class ObservableTaskScheduler implements TaskScheduler { }); return this.impl.resetTaskRetries(taskId); } - reload(): void { + + async reload(): Promise<void> { return this.impl.reload(); } } |