Если кроме onAwait ничего нет
repeat(list.size) {
val str = select<String> {
list.forEach { deferred -> deferred.onAwait { it } }
}
println(str)
}только пару первых значений печатаетSize: a a a
2020 February 03
K
не, чет фигню показывает
DV
Коллеги, кому-нибудь удавалось успешно настроить тимсити с Котлин жс?
AN
да, результат. Ну вот я думал флоу и в его генераторе будет async. Надо запустить все сразу и эмитить по мере успешности выполнения
Вот тут как раз канал. Запомните, если данные пихаете, то канал, если вытягиваете, то Flow
AN
Если запустить кучу асинков, то получать по мере выполнения можно select-ом
В данном случае не надо никаких селектов
AN
Тогда получается, что канал не решает никакой проблемы 🤷♂
Канал решает проблему синхронизации и упорядоченного вывода
AO
Условие выхода - list.notEmpty, в onAwait - отправлять в канал и удалять из списка.
Или бред какой то?
Или бред какой то?
try вам в помощь и какой нибудь Either или свой тип данных
V
try вам в помощь и какой нибудь Either или свой тип данных
Эм?
K
Вот тут как раз канал. Запомните, если данные пихаете, то канал, если вытягиваете, то Flow
Ну, вопрос философский) Когда начинал, со стороны очень казалось, что вытягиваю. Например, обычный GET для одной картинки - вытягивание? А тут вытягивание списка картинок. Инициатор - пользователь, со стороны все выглядит холодным, это ж не сенсор какой-то.
AO
Народ, а какие вообще гарантии на suspend'ах и try finally?
Есть ли кейсы, когда bar не вызовется?
try {
foo() //suspension
} finally {
bar()
}Есть ли кейсы, когда bar не вызовется?
V
Ну, вопрос философский) Когда начинал, со стороны очень казалось, что вытягиваю. Например, обычный GET для одной картинки - вытягивание? А тут вытягивание списка картинок. Инициатор - пользователь, со стороны все выглядит холодным, это ж не сенсор какой-то.
Я правильно понял, все свелось к тому, что нужно просто на каждую ссылку запускать корутину и по готовности кидать картинку в канал? (на примере со списком ссылок на картинки)
K
да вернуть флоу, например, который будет отдавать их по мере поступления.(или, если без флоу, то хоть массив результатов, отсортированый по очередности результатов, но без хаков типа таймстемпа или айдишников).
D
Кто-нибудь научился добавлять сорцы котлина в аар? https://discuss.kotlinlang.org/t/how-to-attach-the-kotlin-library-sources/128/8
V
да вернуть флоу, например, который будет отдавать их по мере поступления.(или, если без флоу, то хоть массив результатов, отсортированый по очередности результатов, но без хаков типа таймстемпа или айдишников).
Эм...а как флоу их будет отдавать по мере поступления?
K
а что не так?
getImages(urls: List<String>):Flow<Image>
getImages(urls: List<String>):Flow<Image>
V
а что не так?
getImages(urls: List<String>):Flow<Image>
getImages(urls: List<String>):Flow<Image>
Не, я про сам эмит.
Как эмитить в порядке загрузки, а не итерации?
Как эмитить в порядке загрузки, а не итерации?
K
пока что похоже я возвращаюсь к ссылке, которую нашёл в самом начале - параллельный флоу, которого ещё нет: https://github.com/Kotlin/kotlinx.coroutines/issues/1147
K
и там чувак что-то нагородил, скрестив флоу с каналом
AO
Народ, а какие вообще гарантии на suspend'ах и try finally?
Есть ли кейсы, когда bar не вызовется?
try {
foo() //suspension
} finally {
bar()
}Есть ли кейсы, когда bar не вызовется?
K
Не, я про сам эмит.
Как эмитить в порядке загрузки, а не итерации?
Как эмитить в порядке загрузки, а не итерации?
вот именно, как!? 😄