Issue #116 : Dispatch network calls to io dispatcher.

Author: lukjj-public-pega

engine-webview/src/iosMain/kotlin/com/pega/constellation/sdk/kmp/engine/webview/ios/ResourceHandler.kt

@@ -3,11 +3,14 @@ package com.pega.constellation.sdk.kmp.engine.webview.ios
 import com.pega.constellation.sdk.kmp.core.Log
 import kotlinx.cinterop.ObjCSignatureOverride
 import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.IO
 import kotlinx.coroutines.Job
 import kotlinx.coroutines.isActive
 import kotlinx.coroutines.launch
 import platform.Foundation.NSData
 import platform.Foundation.NSError
+import platform.Foundation.NSLock
 import platform.Foundation.NSLocalizedDescriptionKey
 import platform.Foundation.NSURLRequest
 import platform.Foundation.NSURLResponse
@@ -26,6 +29,7 @@ class ResourceHandler(
     val mainScope: () -> CoroutineScope
 ) : NSObject(), WKURLSchemeHandlerProtocol {
     lateinit var delegate: ResourceHandlerDelegate
+    private val tasksLock = NSLock()
     private val tasks = mutableMapOf<NSURLRequest, Job>()
 
     private suspend fun send(request: NSURLRequest): Pair<NSData, NSURLResponse> {
@@ -37,7 +41,7 @@ class ResourceHandler(
         webView: WKWebView,
         startURLSchemeTask: WKURLSchemeTaskProtocol
     ) {
-        mainScope().launch {
+        mainScope().launch(Dispatchers.IO) {
             try {
                 Log.i(TAG, "Starting WKURLScheme task. <${startURLSchemeTask.request.URL}>")
                 val (data, response) = send(startURLSchemeTask.request)
@@ -46,7 +50,7 @@ class ResourceHandler(
                     return@launch
                 }
                 Log.i(TAG, "WKURLScheme task is finished. <${startURLSchemeTask.request.URL}>")
-                tasks.remove(startURLSchemeTask.request)
+                tasksLock.withLock { tasks.remove(startURLSchemeTask.request) }
                 startURLSchemeTask.didReceiveResponse(response)
                 startURLSchemeTask.didReceiveData(data)
                 startURLSchemeTask.didFinish()
@@ -59,7 +63,7 @@ class ResourceHandler(
                 startURLSchemeTask.didFailWithError(e.toNSError())
             }
         }.let { job ->
-            tasks[startURLSchemeTask.request] = job
+            tasksLock.withLock { tasks[startURLSchemeTask.request] = job }
         }
     }
 
@@ -69,8 +73,19 @@ class ResourceHandler(
         stopURLSchemeTask: WKURLSchemeTaskProtocol
     ) {
         Log.i(TAG, "Stopping WKURLScheme task. <${stopURLSchemeTask.request.URL}>")
-        tasks[stopURLSchemeTask.request]?.cancel()
-        tasks.remove(stopURLSchemeTask.request)
+        tasksLock.withLock {
+            tasks[stopURLSchemeTask.request]?.cancel()
+            tasks.remove(stopURLSchemeTask.request)
+        }
+    }
+}
+
+private inline fun <T> NSLock.withLock(block: () -> T): T {
+    lock()
+    try {
+        return block()
+    } finally {
+        unlock()
     }
 }
 private fun Throwable.toNSError(): NSError {