We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8fa07b5 commit 58bfd08Copy full SHA for 58bfd08
kotlinx-coroutines-core/common/src/channels/ArrayChannel.kt
@@ -43,7 +43,7 @@ internal open class ArrayChannel<E>(
43
set(value) { _size.value = value }
44
45
protected final override val isBufferAlwaysEmpty: Boolean get() = false
46
- protected final override val isBufferEmpty: Boolean get() = size == 0
+ protected final override val isBufferEmpty: Boolean get() = lock.withLock { size == 0 }
47
protected final override val isBufferAlwaysFull: Boolean get() = false
48
protected final override val isBufferFull: Boolean get() = size == capacity
49
0 commit comments