pubNub.forceDestroy should force okHttpClient executor service to sho…

…utDown immediately.
pubnub · Jan 24, 2025 · 1c153b2 · 1c153b2
1 parent 4f5c588
commit 1c153b2
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 19 deletions.
diff --git a/kotlin-js-store/yarn.lock b/kotlin-js-store/yarn.lock
@@ -659,22 +659,6 @@ proxy-from-env@^1.1.0:
   resolved "https://registry.yarnpkg.com/proxy-from-env/-/proxy-from-env-1.1.0.tgz#e102f16ca355424865755d2c9e8ea4f24d58c3e2"
   integrity sha512-D+zkORCbA9f1tdWRK0RaCR3GPv50cMxcrz4X8k5LTSUD1Dkw47mKJEZQNunItRTkWwgtaUSo1RVFRIG9ZXiFYg==
 
-[email protected]:
-  version "8.4.1"
-  resolved "https://registry.yarnpkg.com/pubnub/-/pubnub-8.4.1.tgz#5f6f19e84d3187dc8aee0a458bd6b05e90d43e6a"
-  integrity sha512-mPlwVoHJDWPasZx52UfSMiPX5TATm5A+ficSogyqDqTQ4w5EQnwxH+PJdsWc0mPnlT051jM1vIISMeM0fQ30CQ==
-  dependencies:
-    agentkeepalive "^3.5.2"
-    buffer "^6.0.3"
-    cbor-js "^0.1.0"
-    cbor-sync "^1.0.4"
-    form-data "^4.0.0"
-    lil-uuid "^0.1.1"
-    node-fetch "^2.7.0"
-    proxy-agent "^6.3.0"
-    react-native-url-polyfill "^2.0.0"
-    text-encoding "^0.7.0"
-
 [email protected]:
   version "8.6.0"
   resolved "https://registry.yarnpkg.com/pubnub/-/pubnub-8.6.0.tgz#75524e7ed3653090652d160ce83ac089362a0379"

diff --git a/...kotlin/pubnub-kotlin-impl/src/main/kotlin/com/pubnub/internal/managers/RetrofitManager.kt b/...kotlin/pubnub-kotlin-impl/src/main/kotlin/com/pubnub/internal/managers/RetrofitManager.kt
@@ -172,10 +172,17 @@ class RetrofitManager(
     ) {
         if (client != null) {
             client.dispatcher.cancelAll()
+            client.connectionPool.evictAll()
+            val executorService = client.dispatcher.executorService
+            executorService.shutdown()
             if (force) {
-                client.connectionPool.evictAll()
-                val executorService = client.dispatcher.executorService
-                executorService.shutdown()
+                try {
+                    if (!executorService.awaitTermination(100, TimeUnit.MILLISECONDS)) {
+                        executorService.shutdownNow()
+                    }
+                } catch (e: InterruptedException) {
+                    executorService.shutdownNow()
+                }
             }
         }
     }