Если что, есть мультиплатформенный Rx. И да, там есть Amb. 😉

Речь как-раз не о единственном сообщении.

У тебя есть 2+ флоу, которые могут сыпать значениями и с помощью amb останется лишь тот источник, что первым прислал значение. Остальные завершаются, остаётся только тот первый.

Да уже ниже разобрались вроде :)

Имеете в виду Reaktive от Badoo?

Подскажите, почему данный код https://pl.kotl.in/XSgupezU8 верно отрабатывается в песочнице, т.е. при отмене родительской job awaitClose вызывается и для дочерней job, а на компьютере нет?

Это какие-то разные версии библиотек?

Версия Kotlin 1.3.72 на компьютере и в песочнице

Версия корутин 1.3.7 на компьютере (какая в песочнице - не знаю)

Скорей всего дочернаяя корутина даже и не успевает запуститься.

Добавьте println(“Started xxx”) в начало каждой корутины (сразу внутри callbackFlow) чтобы видеть что там происходит.

Удивительно, заработало

Спасибо

Почему добавление простого println меняет логику таймаутов?

А хотя, иногда child не успевает запуститься

Т.е. выводит
Started parent
Closing parent

ЧТД

Спасибо еще раз

Привет!
Можете помочь? Я в тупик зашёл. Имеется вот такой пример.

private val scope = CoroutineScope(SupervisorJob() + Dispatchers.Default)

fun main() = runBlocking {
    val channel = BroadcastChannel<String>(1)
    for (i in 0..20) {
        println("iteration ${i + 1} start")
        val job = scope.launch {
            channel.openSubscription()
                .receiveAsFlow()
                .collect { println("receive $it") }
        }

        scope.launch(Dispatchers.IO) {
            channel.send("$i")
        }
        delay(200)
        job.cancel()
    }
    return@runBlocking
}

Но вот println("receive $it") печатает только первые два значения, и я не могу понять, в чем причина.  Может кто-то сможет объяснить