Блог

У меня есть следующий фрагмент кода:

 val flow = MutableSharedFlow<Int>()

launch {
    repeat(10) {
        delay(100)
        println("emitting$it")
        flow.emit(it)
    }
}
    
launch {
    flow.collect {
        delay(1000)
        println("a$it")
    }
}

launch {
    flow.collect {
        println("b$it")
    }
}
 

Я бы ожидал, что результат будет таким:

излучение0 в0 а0 излучение1 в1 а1 …

Из BufferOverflow.SUSPEND — за чего эмиттер вынужден ждать, пока события не будут израсходованы.

Фактический вывод следует этому шаблону, за исключением первых двух элементов, поэтому фактический вывод: излучение 0 b0 излучение 1 b1 a0 (теперь оно начинает следовать поведению, которое я ожидал) излучение 2 b2 a1 излучение 3 b3 a2 …

Что вызывает выброс второго элемента? Не следует ли подождать, пока будет потреблен первый товар?

Это действительно подождет. Что вас смущает, так это delay(1000) перед печатью a# . К тому времени, когда он печатает a# , прошла 1 секунда с тех пор, как он начал его потреблять. Поменяйте их местами, и вы это ясно увидите.

 flow.collect {
    println("a$it")
    delay(1000)
}
 

Вы также можете распечатать что-то еще после отправки элемента, чтобы сделать его еще более четким:

 repeat(10) {
    delay(100)
    println("emitting$it")
    flow.emit(it)
    println("emited$it")
}
 

Вот что он выводит:

 emitting0
a0
b0
emited0
emitting1
b1
a1
emited1
emitting2
b2
a2
emited2
...