feat: cancelAllRequests

Author: farfromrefug

src/https/request.android.ts

@@ -405,6 +405,32 @@ export function cancelRequest(tag: string, client: okhttp3.OkHttpClient = runnin
     }
 }
 
+export function cancelAllRequests() {
+    Object.values(notClosedResponses).forEach((req) => req.cancel());
+
+    Object.values(runningClients).forEach((client) => {
+        const dispatcher = client.dispatcher();
+        //When you want to cancel:
+        //A) go through the queued calls and cancel if the tag matches:
+        if (dispatcher.queuedCallsCount() > 0) {
+            const queuedCalls = dispatcher.queuedCalls();
+            for (let index = 0; index < queuedCalls.size(); index++) {
+                const call = queuedCalls.get(index);
+                call.cancel();
+            }
+        }
+
+        //B) go through the running calls and cancel if the tag matches:
+        if (dispatcher.runningCallsCount() > 0) {
+            const runningCalls = dispatcher.runningCalls();
+            for (let index = 0; index < runningCalls.size(); index++) {
+                const call = runningCalls.get(index);
+                call.cancel();
+            }
+        }
+    });
+}
+
 export function clearCookies() {
     if (cookieJar) {
         cookieJar = null;
@@ -478,7 +504,6 @@ export function createRequest(opts: HttpsRequestOptions, useLegacy: boolean = tr
                 }
             });
             okHttpBody = builder.build();
-            
         } else if (type === 'application/x-www-form-urlencoded') {
             const builder = new okhttp3.FormBody.Builder();
             Object.keys(opts.body).forEach((key) => {

src/https/request.d.ts

@@ -112,6 +112,7 @@ export function setCache(options?: CacheOptions);
 export function clearCache();
 export function createRequest(opts: HttpsRequestOptions): HttpsRequest;
 export function cancelRequest(tag: string);
+export function cancelAllRequests();
 export function clearCookies();
 export function addNetworkInterceptor(interceptor);
 

src/https/request.ios.ts

@@ -308,6 +308,11 @@ export function cancelRequest(tag: string) {
         runningRequests[tag].cancel();
     }
 }
+export function cancelAllRequests() {
+    Object.values(runningRequests).forEach(request=>{
+        request.cancel()
+    })
+}
 
 export function clearCookies() {
     const storage = NSHTTPCookieStorage.sharedHTTPCookieStorage;