taler-typescript-core

commit 0b8b9950d003e215399886a6611212d4b2666166
parent 99e4c82ca2c47c10d80f7320ba5638741ed3b420
Author: Sebastian <sebasjm@gmail.com>
Date:   Tue, 12 Mar 2024 08:11:00 -0300

fix #8489

Diffstat:
M
packages/taler-util/src/observability.ts
 | 
10
++++++----

1 file changed, 6 insertions(+), 4 deletions(-)
diff --git 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)
     }
   }
 }