Практика потоков в Kotlin
Поток отдает числа 1, 2, 3.
Оставьте только значения больше 1,
удвойте каждое через цепочку операторов и
выведите результат в runBlocking.
Дан список:
val words = listOf("api", "ui", "log")
Превратите его в поток, возьмите первые две строки, переведите в верхний регистр и напечатайте каждую.
Три раза подряд с интервалом 25
миллисекунд отправьте одно и то же число
42, затем выдержите паузу 150
миллисекунд. Соберите поток с прореживанием
100 миллисекунд - наружу должно
выйти одно значение.
Поток печатает "ok" и затем падает с
ошибкой. Подключите обработчик, который
отправляет "fix", и соберите обе
строки по порядку.
Потоки 1, 2 и "a",
"b", "c" свяжите попарно по
индексу в строки "1-a" и аналогичные.
Выведите все пары для общей длины более
короткого источника.
Класс MutableStateFlow хранит строку
"v1". Запишите "v2", запустите
сбор, снова запишите "v3" и убедитесь,
что первый сбор увидел "v2", а второй
запуск сбора сразу получает "v3".
Общая шина без повтора: до подписки отправьте
1, после старта фонового сбора -
2. В консоли должно появиться только
второе число.