修复async操作符异步任务失效问题

liujingxing · liujingxing · commit 90fd4bf47a51 · 2020-05-10T12:20:35.000+08:00
diff --git a/rxhttp/src/main/java/rxhttp/IAwait.kt b/rxhttp/src/main/java/rxhttp/IAwait.kt
@@ -1,6 +1,8 @@
 package rxhttp
 
-import kotlinx.coroutines.*
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Deferred
+import kotlinx.coroutines.async
 import rxhttp.wrapper.await.*
 
 /**
@@ -42,7 +44,7 @@ fun <T> IAwait<T>.delay(delay: Long): IAwait<T> = AwaitDelay(this, delay)
 
 fun <T> IAwait<T>.startDelay(delay: Long): IAwait<T> = AwaitStartDelay(this, delay)
 
-suspend fun <T> IAwait<T>.async() = supervisorScope { async { await() } }
+suspend fun <T> IAwait<T>.async(scope: CoroutineScope) = scope.async { await() }
 
 suspend fun <T> Deferred<T>.tryAwait() = tryAwait { await() }
 
