Start InterruptibleSource in UNINTERRUPTIBLE state. (#510)

coil-kt · Aug 28, 2020 · b3bc498 · b3bc498
1 parent 2dd9737
commit b3bc498
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/coil-base/src/main/java/coil/decode/InterruptibleSource.kt b/coil-base/src/main/java/coil/decode/InterruptibleSource.kt
@@ -54,7 +54,7 @@ internal class InterruptibleSource(
     delegate: Source
 ) : ForwardingSource(delegate), CompletionHandler {
 
-    private val _state = AtomicInteger(WORKING)
+    private val _state = AtomicInteger(UNINTERRUPTIBLE)
     private val targetThread = Thread.currentThread()
 
     init {
@@ -64,8 +64,8 @@ internal class InterruptibleSource(
         run {
             _state.loop { state ->
                 when (state) {
-                    WORKING -> if (_state.compareAndSet(state, WORKING)) return@run
-                    INTERRUPTING, INTERRUPTED -> return@run
+                    UNINTERRUPTIBLE -> if (_state.compareAndSet(state, UNINTERRUPTIBLE)) return@run
+                    PENDING, INTERRUPTING, INTERRUPTED -> return@run
                     else -> invalidState(state)
                 }
             }