File tree 1 file changed +3
-2
lines changed
kotlinx-coroutines-core/common/src
1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -6,6 +6,7 @@ package kotlinx.coroutines
6
6
7
7
import kotlinx.atomicfu.*
8
8
import kotlin.coroutines.*
9
+ import kotlin.jvm.*
9
10
10
11
/* *
11
12
* Awaits for completion of given deferred values without blocking a thread and resumes normally with the list of values
@@ -103,8 +104,8 @@ private class AwaitAll<T>(private val deferreds: Array<out Deferred<T>>) {
103
104
private inner class AwaitAllNode (private val continuation : CancellableContinuation <List <T >>) : JobNode() {
104
105
lateinit var handle: DisposableHandle
105
106
106
- private val _disposer = atomic< DisposeHandlersOnCancel ?>( null )
107
- var disposer: DisposeHandlersOnCancel ? by _disposer
107
+ @Volatile
108
+ var disposer: DisposeHandlersOnCancel ? = null
108
109
109
110
override fun invoke (cause : Throwable ? ) {
110
111
if (cause != null ) {
You can’t perform that action at this time.
0 commit comments