File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
kotlinx-coroutines-core/common/src/channels Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -19,7 +19,7 @@ import kotlinx.coroutines.selects.*
1919 */
2020internal open class ConflatedChannel <E >(onUndeliveredElement : OnUndeliveredElement <E >? ) : AbstractChannel<E>(onUndeliveredElement) {
2121 protected final override val isBufferAlwaysEmpty: Boolean get() = false
22- protected final override val isBufferEmpty: Boolean get() = value == = EMPTY
22+ protected final override val isBufferEmpty: Boolean get() = lock.withLock { value == = EMPTY }
2323 protected final override val isBufferAlwaysFull: Boolean get() = false
2424 protected final override val isBufferFull: Boolean get() = false
2525
@@ -139,5 +139,5 @@ internal open class ConflatedChannel<E>(onUndeliveredElement: OnUndeliveredEleme
139139 // ------ debug ------
140140
141141 override val bufferDebugString: String
142- get() = " (value=$value )"
142+ get() = lock.withLock { " (value=$value )" }
143143}
You can’t perform that action at this time.
0 commit comments