From 2f478f1b9da93ffebc087f85e9346725d827debc Mon Sep 17 00:00:00 2001
From: "Hung-Han (Henry) Chen" <chenhungh@gmail.com>
Date: Mon, 22 Nov 2021 14:53:13 +0200
Subject: [PATCH] Use opts.abortController.abort?.() if present

Signed-off-by: Hung-Han (Henry) Chen <chenhungh@gmail.com>
---
 src/common/k8s-api/kube-api.ts | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/src/common/k8s-api/kube-api.ts b/src/common/k8s-api/kube-api.ts
index 6bdf26e496..44c50864bd 100644
--- a/src/common/k8s-api/kube-api.ts
+++ b/src/common/k8s-api/kube-api.ts
@@ -584,7 +584,11 @@ export class KubeApi<T extends KubeObject> {
       logger.info(`[KUBE-API] system suspended, abort watching of ${watchUrl}...`);
 
       try {
-        abort();
+        if (opts.abortController) {
+          opts.abortController.abort?.();
+        } else {
+          abort?.();
+        }
       } catch (error) {
         logger.error(`[KUBE-API] error aborting watch (${watchId})`, error);
       }