We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent fe64780 commit a0f7666Copy full SHA for a0f7666
kotlinx-coroutines-core/common/src/flow/internal/AbstractSharedFlow.kt
@@ -45,7 +45,7 @@ internal abstract class AbstractSharedFlow<S : AbstractSharedFlowSlot<*>> : Sync
45
// Actually create slot under lock
46
var subscriptionCount: MutableStateFlow<Int>? = null
47
val slot = synchronized(this) {
48
- val slots = when(val curSlots = slots) {
+ val slots = when (val curSlots = slots) {
49
null -> createSlotArray(2).also { slots = it }
50
else -> if (nCollectors >= curSlots.size) {
51
curSlots.copyOf(2 * curSlots.size).also { slots = it }
0 commit comments