1 files changed, 6 insertions, 6 deletions
diff --git a/packages/taler-wallet-core/src/wallet.ts b/packages/taler-wallet-core/src/wallet.ts
index 733c239f9..ed174e33b 100644
--- a/packages/taler-wallet-core/src/wallet.ts
+++ b/packages/taler-wallet-core/src/wallet.ts
@@ -208,7 +208,7 @@ import {
   processPeerPullCredit,
   processPeerPullDebit,
   processPeerPushCredit,
-  processPeerPushInitiation,
+  processPeerPushDebit,
 } from "./operations/pay-peer.js";
 import { getPendingOperations } from "./operations/pending.js";
 import {
@@ -314,9 +314,9 @@ async function callOperationHandler(
     }
     case PendingTaskType.Backup:
       return await processBackupForProvider(ws, pending.backupProviderBaseUrl);
-    case PendingTaskType.PeerPushInitiation:
-      return await processPeerPushInitiation(ws, pending.pursePub);
-    case PendingTaskType.PeerPullInitiation:
+    case PendingTaskType.PeerPushDebit:
+      return await processPeerPushDebit(ws, pending.pursePub);
+    case PendingTaskType.PeerPullCredit:
       return await processPeerPullCredit(ws, pending.pursePub);
     case PendingTaskType.PeerPullDebit:
       return await processPeerPullDebit(ws, pending.peerPullPaymentIncomingId);
@@ -439,7 +439,7 @@ async function runTaskLoop(
       });
       // Wait until either the timeout, or we are notified (via the latch)
       // that more work might be available.
-      await Promise.race([timeout, ws.latch.wait()]);
+      await Promise.race([timeout, ws.workAvailable.wait()]);
     } else {
       logger.trace(
         `running ${pending.pendingOperations.length} pending operations`,
@@ -1659,7 +1659,7 @@ class InternalWalletStateImpl implements InternalWalletState {
   merchantInfoCache: Record<string, MerchantInfo> = {};
 
   readonly timerGroup: TimerGroup;
-  latch = new AsyncCondition();
+  workAvailable = new AsyncCondition();
   stopped = false;
 
   listeners: NotificationListener[] = [];