просто прекращать collect надо с помощью take(...) или takeWhile(...)

Ой да ладно

ну ты по-моему так и сделал

хаха, котик не может в джеб. И тайминг у цыпы лучше

/cat@relaxcats_bot

#nsfw

Да ну, это просто массаж)

https://t.me/pofftop/246737
Да вон же ж Миша объяснил. Это аналог реактивных стримов, сделанный в корутинах котлиновских.

реактивные стримы будут с третьей волны ковида, митапы с горшка

Некоторым странам хотя бы вторую пережить

ну и чего его мусолить вторые сутки, какие вообще могут быть проблемы у стрима? это просто асинхронный источник событий , лови да обрабатывай.

вангую всё выкинут это, когда лум запилят до стабильного состояния. обычный BlockingQueue станет а-ля гошным каналом, и никто не будет трахать себе мозг этими избыточными абстракциями

Пока его использовать начнут состариться успеем

пичаль, жалко. проект же огонь, решает реальные задачи, в отличии от корутин и всяикх рыхов

Я не совсем понял, какое отношение к этому имеют корутины. Семантически это способ выражать хоть холодный, хоть горячий поток данных, и делать на нём разные трансформации. Каналы гошные (и котлиновские) не об этом. С чего вдруг откажутся от этой абстракции, если лум ровно ничего не меняет?

Смешно)

лум меняет всё. он решает проблему большого потребления ресурсов, большинством либ жвм экосистемы. они жрут много потому-что создают овер дохуя тредов и они дорогие (поэтому, если критичен IO на много потребеителей почти любой современный проект постатаерся не использовать жвм, если есть такая возможность). лум эту проблему решает. корутины, рыхи итд. - просто про эстетику, они не решают вообще нихрена, это просто для красоты скажем так и для душевного спокойствия разраба.
поток данных это поток данных, холодный он или горячий это вообще мелочь, никто об этом не запаривался особо как и большей части structured concurrency которая больше похожа на маркетинг провалившихся на беке корутин.
с лумом (в том виде, в каком он должен был быть) можно было бы взять реально сложный проект где-то в недрах тырпрайза, обмазанные ораклами, сапами, проприетарными mq и в разы улучшить его перфоманс. с кокорутинами, можно веслее написать код и не более того, никаких фундмаентальных проблем они не решат.

О, кстати о structured concurrency. Где там в луме cancellation propagation?

Как лум решает проблему семантики асинхронных вызовов?