bug fix

Author: wenxi-zeng

core/src/main/java/com/segment/analytics/kotlin/core/Waiting.kt

@@ -27,34 +27,36 @@ interface WaitingPlugin: Plugin {
     }
 }
 
-fun Analytics.pauseEventProcessing(plugin: WaitingPlugin) = analyticsScope.launch {
+fun Analytics.pauseEventProcessing(plugin: WaitingPlugin) = analyticsScope.launch(analyticsDispatcher) {
     store.dispatch(System.AddWaitingPlugin(plugin.hashCode()), System::class)
+    pauseEventProcessing()
 }
 
 
-fun Analytics.resumeEventProcessing(plugin: WaitingPlugin) = analyticsScope.launch {
+fun Analytics.resumeEventProcessing(plugin: WaitingPlugin) = analyticsScope.launch(analyticsDispatcher) {
     store.dispatch(System.RemoveWaitingPlugin(plugin.hashCode()), System::class)
+    resumeEventProcessing()
 }
 
 internal suspend fun Analytics.running(): Boolean {
     val system = store.currentState(System::class)
     return system?.running ?: false
 }
 
-internal suspend fun Analytics.pauseEventProcessing() {
+internal suspend fun Analytics.pauseEventProcessing(timeout: Long = 30_000) {
     if (!running()) return
 
     store.dispatch(System.ToggleRunningAction(false), System::class)
-    startProcessingAfterTimeout()
+    startProcessingAfterTimeout(timeout)
 }
 
 internal suspend fun Analytics.resumeEventProcessing() {
     if (running()) return
     store.dispatch(System.ToggleRunningAction(true), System::class)
 }
 
-internal fun Analytics.startProcessingAfterTimeout() = analyticsScope.launch {
-    delay(30_000)
+internal fun Analytics.startProcessingAfterTimeout(timeout: Long) = analyticsScope.launch(analyticsDispatcher) {
+    delay(timeout)
     store.dispatch(System.ForceRunningAction(), System::class)
 }