From 0b8b9950d003e215399886a6611212d4b2666166 Mon Sep 17 00:00:00 2001
From: Sebastian <sebasjm@gmail.com>
Date: Tue, 12 Mar 2024 08:11:00 -0300
Subject: fix #8489

---
 packages/taler-util/src/observability.ts | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

(limited to 'packages/taler-util/src')

diff --git a/packages/taler-util/src/observability.ts b/packages/taler-util/src/observability.ts
index f40967c52..70391cbcd 100644
--- a/packages/taler-util/src/observability.ts
+++ b/packages/taler-util/src/observability.ts
@@ -38,14 +38,14 @@ export interface ObservabilityContext {
 let seqId = 1000;
 
 export class ObservableHttpClientLibrary implements HttpRequestLibrary {
-  private readonly currentRequest = new Map<string, CancellationToken.Source>();
+  private readonly cancelatorById = new Map<string, CancellationToken.Source>();
   constructor(
     private impl: HttpRequestLibrary,
     private oc: ObservabilityContext,
   ) {}
 
-  public cancelRequest(id: string) {
-    const cancelator = this.currentRequest.get(id);
+  public cancelRequest(id: string): void {
+    const cancelator = this.cancelatorById.get(id);
     if (!cancelator) return;
     cancelator.cancel();
   }
@@ -61,7 +61,7 @@ export class ObservableHttpClientLibrary implements HttpRequestLibrary {
     if (opt?.cancellationToken) {
       opt.cancellationToken.onCancelled(cancelator.cancel);
     }
-    this.currentRequest.set(id, cancelator);
+    this.cancelatorById.set(id, cancelator);
 
     this.oc.observe({
       id,
@@ -91,6 +91,8 @@ export class ObservableHttpClientLibrary implements HttpRequestLibrary {
         error: getErrorDetailFromException(e),
       });
       throw e;
+    } finally {
+      this.cancelatorById.delete(id)
     }
   }
 }
-- 
cgit v1.2.3