SharedFlow stops emitting values

[AndreyArapov]

If I use the replay parameter in the MutableSharedFlow function, then at some point in time the flow stops emitting values. The problem is reproducible if subscribers process values with different delays. But if the delays are equal, then it works correctly.

Сode:

private val state = MutableSharedFlow<Int>(1)

fun main() {
    val delay1: Long = 100
    val delay2: Long = 400
    state
        .onEach {
            delay(delay1)
            println("item1 = $it")
        }.launchIn(GlobalScope)

    state
        .onEach {
            delay(delay2)
            println("item2 = $it")
        }.launchIn(GlobalScope)


    val job = GlobalScope.launch(Dispatchers.IO) {
        delay(1.seconds)
        for (i in 0..5) {
            state.emit(i)
            println("emit = $i")
            delay(100)
        }
    }

    runBlocking {
        delay(10.seconds)
        println("Job = $job")
    }
}

Result:

emit = 0
emit = 1
value1 = 0
value1 = 1
value2 = 0
emit = 2
value2 = 1
value2 = 2
Job = "coroutine#3":StandaloneCoroutine{Active}

[elizarov]

Thanks a lot for the report! Will be fixed.