aboutsummaryrefslogtreecommitdiff
path: root/packages/taler-wallet-core/src/testing.ts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/taler-wallet-core/src/testing.ts')
-rw-r--r--packages/taler-wallet-core/src/testing.ts12
1 files changed, 6 insertions, 6 deletions
diff --git a/packages/taler-wallet-core/src/testing.ts b/packages/taler-wallet-core/src/testing.ts
index bcb6abca0..22af816e5 100644
--- a/packages/taler-wallet-core/src/testing.ts
+++ b/packages/taler-wallet-core/src/testing.ts
@@ -402,7 +402,7 @@ export async function waitUntilAllTransactionsFinal(
ws: InternalWalletState,
): Promise<void> {
logger.info("waiting until all transactions are in a final state");
- ws.ensureTaskLoopRunning();
+ ws.taskScheduler.ensureRunning();
let p: OpenedPromise<void> | undefined = undefined;
const cancelNotifs = ws.addNotificationListener((notif) => {
if (!p) {
@@ -462,7 +462,7 @@ export async function waitUntilGivenTransactionsFinal(
if (transactionIds.length === 0) {
return;
}
- ws.ensureTaskLoopRunning();
+ ws.taskScheduler.ensureRunning();
const txIdSet = new Set(transactionIds);
let p: OpenedPromise<void> | undefined = undefined;
const cancelNotifs = ws.addNotificationListener((notif) => {
@@ -522,7 +522,7 @@ export async function waitUntilRefreshesDone(
ws: InternalWalletState,
): Promise<void> {
logger.info("waiting until all refresh transactions are in a final state");
- ws.ensureTaskLoopRunning();
+ ws.taskScheduler.ensureRunning();
let p: OpenedPromise<void> | undefined = undefined;
const cancelNotifs = ws.addNotificationListener((notif) => {
if (!p) {
@@ -576,7 +576,7 @@ async function waitUntilTransactionPendingReady(
transactionId: string,
): Promise<void> {
logger.info(`starting waiting for ${transactionId} to be in pending(ready)`);
- ws.ensureTaskLoopRunning();
+ ws.taskScheduler.ensureRunning();
let p: OpenedPromise<void> | undefined = undefined;
const cancelNotifs = ws.addNotificationListener((notif) => {
if (!p) {
@@ -617,7 +617,7 @@ export async function waitTransactionState(
txState,
)})`,
);
- ws.ensureTaskLoopRunning();
+ ws.taskScheduler.ensureRunning();
let p: OpenedPromise<void> | undefined = undefined;
const cancelNotifs = ws.addNotificationListener((notif) => {
if (!p) {
@@ -669,7 +669,7 @@ export async function runIntegrationTest2(
ws: InternalWalletState,
args: IntegrationTestV2Args,
): Promise<void> {
- ws.ensureTaskLoopRunning();
+ ws.taskScheduler.ensureRunning();
logger.info("running test with arguments", args);
const exchangeInfo = await fetchFreshExchange(ws, args.exchangeBaseUrl);