fix: run all io operations on io dispatcher (#32)

Author: patrickkabwe

android/src/main/java/com/nitrofs/FileDownloader.kt

@@ -1,7 +1,5 @@
 package com.nitrofs
 
-import android.os.Handler
-import android.os.Looper
 import io.ktor.client.HttpClient
 import io.ktor.client.call.body
 import io.ktor.client.engine.okhttp.OkHttp
@@ -11,6 +9,8 @@ import io.ktor.http.HttpMethod
 import io.ktor.util.cio.writeChannel
 import io.ktor.utils.io.ByteReadChannel
 import io.ktor.utils.io.copyAndClose
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.withContext
 import java.io.File
 
 class FileDownloader {
@@ -30,7 +30,7 @@ class FileDownloader {
                 onDownload { totalBytesSent, contentLength ->
                     if (totalBytesSent > 0 && contentLength != null){
                         onProgress?.let {
-                            Handler(Looper.getMainLooper()).post {
+                            withContext(Dispatchers.Main) {
                                 onProgress.invoke(totalBytesSent.toDouble(), contentLength.toDouble())
                             }
                         }

android/src/main/java/com/nitrofs/HybridNitroFS.kt

@@ -8,10 +8,13 @@ import com.margelo.nitro.nitrofs.NitroFile
 import com.margelo.nitro.nitrofs.NitroFileEncoding
 import com.margelo.nitro.nitrofs.NitroFileStat
 import com.margelo.nitro.nitrofs.NitroUploadOptions
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
 
 class HybridNitroFS: HybridNitroFSSpec() {
     val context = NitroModules.applicationContext ?: error("React Native context not found")
     val nitroFsImpl = NitroFSImpl(context)
+    val ioScope = CoroutineScope(Dispatchers.IO)
 
     override val BUNDLE_DIR: String
         get() = ""
@@ -34,7 +37,7 @@ class HybridNitroFS: HybridNitroFSSpec() {
         data: String,
         encoding: NitroFileEncoding
     ): Promise<Unit> {
-        return Promise.async {
+        return Promise.async(ioScope) {
             try {
                 nitroFsImpl.writeFile(path, data, encoding)
             } catch (e: Exception) {
@@ -48,7 +51,7 @@ class HybridNitroFS: HybridNitroFSSpec() {
         path: String,
         encoding: NitroFileEncoding
     ): Promise<String> {
-        return Promise.async {
+        return Promise.async(ioScope) {
             try {
                 nitroFsImpl.readFile(path, encoding)
             } catch (e: Exception) {
@@ -62,7 +65,7 @@ class HybridNitroFS: HybridNitroFSSpec() {
         srcPath: String,
         destPath: String
     ): Promise<Unit> {
-        return Promise.async {
+        return Promise.async(ioScope) {
             try {
                 nitroFsImpl.copyFile(srcPath, destPath)
             } catch (e: Exception) {
@@ -80,7 +83,7 @@ class HybridNitroFS: HybridNitroFSSpec() {
     }
 
     override fun unlink(path: String): Promise<Boolean> {
-        return Promise.async {
+        return Promise.async(ioScope) {
             try {
                 nitroFsImpl.unlink(path)
             } catch (e: Exception) {
@@ -91,7 +94,7 @@ class HybridNitroFS: HybridNitroFSSpec() {
     }
 
     override fun mkdir(path: String): Promise<Boolean> {
-        return Promise.async {
+        return Promise.async(ioScope) {
             try {
                 nitroFsImpl.mkdir(path)
             } catch (e: Exception) {
@@ -102,7 +105,7 @@ class HybridNitroFS: HybridNitroFSSpec() {
     }
 
     override fun stat(path: String): Promise<NitroFileStat> {
-        return Promise.async {
+        return Promise.async(ioScope) {
             nitroFsImpl.stat(path)
         }
     }
@@ -112,7 +115,7 @@ class HybridNitroFS: HybridNitroFSSpec() {
         uploadOptions: NitroUploadOptions,
         onProgress: ((Double, Double) -> Unit)?
     ): Promise<Unit> {
-        return Promise.async {
+        return Promise.async(ioScope) {
             try {
                 nitroFsImpl.uploadFile(file, uploadOptions, onProgress)
             } catch (e: Exception) {
@@ -128,7 +131,7 @@ class HybridNitroFS: HybridNitroFSSpec() {
         destinationPath: String,
         onProgress: ((Double, Double) -> Unit)?
     ): Promise<NitroFile> {
-        return Promise.async {
+        return Promise.async(ioScope) {
             try {
                 nitroFsImpl.downloadFile(serverUrl, fileName, destinationPath, onProgress)
                 NitroFile(

android/src/main/java/com/nitrofs/NitroFileUploader.kt

@@ -1,7 +1,5 @@
 package com.nitrofs
 
-import android.os.Handler
-import android.os.Looper
 import io.ktor.client.HttpClient
 import com.margelo.nitro.nitrofs.NitroUploadMethod
 import com.margelo.nitro.nitrofs.NitroUploadOptions
@@ -14,6 +12,8 @@ import io.ktor.http.Headers
 import io.ktor.http.HttpHeaders
 import io.ktor.http.HttpMethod
 import io.ktor.utils.io.streams.asInput
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.withContext
 import java.io.File
 
 class NitroFileUploader {
@@ -45,7 +45,7 @@ class NitroFileUploader {
                 onUpload { totalBytesSent, totalBytes ->
                     if (totalBytesSent > 0 && totalBytes != null) {
                         onProgress?.let {
-                            Handler(Looper.getMainLooper()).post {
+                            withContext(Dispatchers.Main) {
                                 it.invoke(totalBytesSent.toDouble(), totalBytes.toDouble())
                             }
                         }