try something

Author: prayansh

core/src/main/java/com/segment/analytics/kotlin/core/platform/EventPipeline.kt

@@ -1,14 +1,23 @@
 package com.segment.analytics.kotlin.core.platform
 
-import com.segment.analytics.kotlin.core.*
-import com.segment.analytics.kotlin.core.platform.plugins.logger.*
-import kotlinx.coroutines.*
+import com.segment.analytics.kotlin.core.Analytics
+import com.segment.analytics.kotlin.core.Constants
+import com.segment.analytics.kotlin.core.HTTPClient
+import com.segment.analytics.kotlin.core.HTTPException
+import com.segment.analytics.kotlin.core.Storage
+import com.segment.analytics.kotlin.core.parseFilePaths
+import com.segment.analytics.kotlin.core.platform.plugins.logger.LogFilterKind
+import com.segment.analytics.kotlin.core.platform.plugins.logger.log
+import com.segment.analytics.kotlin.core.platform.plugins.logger.segmentLog
 import kotlinx.coroutines.channels.Channel
 import kotlinx.coroutines.channels.Channel.Factory.UNLIMITED
 import kotlinx.coroutines.channels.consumeEach
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.isActive
+import kotlinx.coroutines.launch
+import kotlinx.coroutines.withContext
 import java.io.File
 import java.io.FileInputStream
-import java.lang.Exception
 import java.util.concurrent.atomic.AtomicInteger
 
 internal class EventPipeline(
@@ -178,10 +187,10 @@ internal class EventPipeline(
 
     private fun registerShutdownHook() {
         // close the stream if the app shuts down
-        Runtime.getRuntime().addShutdownHook(object : Thread() {
-            override fun run() {
-                this@EventPipeline.stop()
-            }
-        })
+//        Runtime.getRuntime().addShutdownHook(object : Thread() {
+//            override fun run() {
+//                this@EventPipeline.stop()
+//            }
+//        })
     }
 }

core/src/main/java/com/segment/analytics/kotlin/core/utilities/EventsFileManager.kt

@@ -169,11 +169,11 @@ class EventsFileManager(
 
     private fun registerShutdownHook() {
         // close the stream if the app shuts down
-        Runtime.getRuntime().addShutdownHook(object : Thread() {
-            override fun run() {
-                os?.close()
-            }
-        })
+//        Runtime.getRuntime().addShutdownHook(object : Thread() {
+//            override fun run() {
+//                os?.close()
+//            }
+//        })
     }
 
     private suspend fun withLock(block: () -> Unit) {