修复storage接口回调没有执行在主线程的问题

app/src/main/java/com/maxrocky/nativeview/contract/StorageContract.kt

@@ -12,6 +12,7 @@ import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.flow.collect
 import kotlinx.coroutines.flow.collect
 import kotlinx.coroutines.flow.map
 import kotlinx.coroutines.flow.map
 import kotlinx.coroutines.launch
 import kotlinx.coroutines.launch
+import kotlinx.coroutines.withContext
 
 
 class StorageContract(fragment: Fragment, proxy: WebViewProxy) : IContract(fragment, proxy){
 class StorageContract(fragment: Fragment, proxy: WebViewProxy) : IContract(fragment, proxy){
     companion object {
     companion object {
@@ -32,12 +33,16 @@ class StorageContract(fragment: Fragment, proxy: WebViewProxy) : IContract(fragm
                     val storageKey = stringPreferencesKey(key)
                     val storageKey = stringPreferencesKey(key)
                     maxrocky[storageKey] = value
                     maxrocky[storageKey] = value
                     val data = StorageResult(key, value)
                     val data = StorageResult(key, value)
-                    proxy.success(STORAGE_METHOD, storageResult, data)
-                    storageResult.reset()
+                    withContext(Dispatchers.Main) {
+                        proxy.success(STORAGE_METHOD, storageResult, data)
+                        storageResult.reset()
+                    }
                 }
                 }
             } catch (e: Exception) {
             } catch (e: Exception) {
-                proxy.failed(STORAGE_METHOD, storageResult, e.message ?: "")
-                storageResult.reset()
+                withContext(Dispatchers.Main) {
+                    proxy.failed(STORAGE_METHOD, storageResult, e.message ?: "")
+                    storageResult.reset()
+                }
             }
             }
         }
         }
     }
     }
@@ -48,12 +53,16 @@ class StorageContract(fragment: Fragment, proxy: WebViewProxy) : IContract(fragm
             try {
             try {
                 context.dataStore.data.map { it[stringPreferencesKey(key)] ?: "" }.collect { storageValue ->
                 context.dataStore.data.map { it[stringPreferencesKey(key)] ?: "" }.collect { storageValue ->
                     val data = StorageResult(key, storageValue)
                     val data = StorageResult(key, storageValue)
-                    proxy.success(ACQUIRE_METHOD, acquireResult, data)
-                    acquireResult.reset()
+                    withContext(Dispatchers.Main) {
+                        proxy.success(ACQUIRE_METHOD, acquireResult, data)
+                        acquireResult.reset()
+                    }
                 }
                 }
             } catch (e: Exception) {
             } catch (e: Exception) {
-                proxy.failed(ACQUIRE_METHOD, acquireResult, e.message ?: "")
-                acquireResult.reset()
+                withContext(Dispatchers.Main) {
+                    proxy.failed(ACQUIRE_METHOD, acquireResult, e.message ?: "")
+                    acquireResult.reset()
+                }
             }
             }
         }
         }
     }
     }
@@ -69,12 +78,16 @@ class StorageContract(fragment: Fragment, proxy: WebViewProxy) : IContract(fragm
                     }
                     }
                     val storageValue = maxrocky.remove(storageKey)
                     val storageValue = maxrocky.remove(storageKey)
                     val data = StorageResult(key, storageValue)
                     val data = StorageResult(key, storageValue)
-                    proxy.success(CLEAR_METHOD, clearResult, data)
-                    clearResult.reset()
+                    withContext(Dispatchers.Main) {
+                        proxy.success(CLEAR_METHOD, clearResult, data)
+                        clearResult.reset()
+                    }
                 }
                 }
             } catch (e: Exception) {
             } catch (e: Exception) {
-                proxy.failed(CLEAR_METHOD, clearResult, e.message ?: "")
-                clearResult.reset()
+                withContext(Dispatchers.Main) {
+                    proxy.failed(CLEAR_METHOD, clearResult, e.message ?: "")
+                    clearResult.reset()
+                }
             }
             }
         }
         }
     }
     }