Есть ли способ получить то же поведение, что и фрагмент кода ниже, но с использованием сопрограмм? Обновлен фрагмент кода: fun main(args: Array<String>) = runBlocking { val executor = Executors.newFixedThreadPool(50)...

Я экспериментирую с Kotlin Coroutines и имею следующий код: fun main(args: Array<String>) = runBlocking { val cores = Runtime.getRuntime().availableProcessors() println("number of cores: $cores") val jobs = List(10) {...

Я нашел следующую реализацию включающего takeWhile (найдено здесь ) fun <T> Sequence<T>.takeWhileInclusive(pred: (T) -> Boolean): Sequence<T> { var shouldContinue = true return takeWhile { val result =...

Есть ли какой-нибудь необычный способ реализовать debounce логику с помощью Kotlin Android? Я не использую Rx в проекте. Есть способ в Java , но он слишком велик, как для меня здесь.

Что мне нужно изменить в моем build.gradle файле или импортировать в классы, чтобы использовать стабильные функции сопрограмм в моем проекте Android с Kotlin 1.3? Фрагмент про сопрограммы в моем build.gradle implementation...

Я читал о параллелизме в Kotlin и думал, что начал его понимать... Затем я обнаружил, что async() устарел в 1.3, и я вернулся к началу. Вот что я хотел бы сделать: создать поток (и, к сожалению, это должен быть поток, а не управляемый пул), а...

Предположим, я хочу использовать кеш в DownloadQueue , например . Преимущество сопрограмм в том, что простая структура данных (например, HashMap ) может использоваться в однопоточном алгоритме. Однако я хочу использовать ограниченный кеш и...

В настоящее время я разрабатываю библиотеку сохранения для Android в Kotlin. В моем коде мне приходится обрабатывать файловые операции (чтение, запись и т. д.), которые я хотел бы выполнять асинхронно из соображений производительности. Я думал, что...

Я начал использовать коротуины, когда они еще были экспериментальными. С anko у меня было что-то вроде async(UI) { val request = bg { sendRequest() } val result = request.await() // UI work } Мне очень нравится, как он...

Я хочу создать долгоживущий сервис, который может обрабатывать события. Он получает события через postEvent , сохраняет их в репозитории (с базовой базой данных) и отправляет их пакет API, когда событий достаточно. Также я хотел бы закрыть его по...

Как использовать новые сопрограммы Kotlin v1.3 в классах, не имеющих жизненных циклов, например в репозиториях? У меня есть класс, в котором я проверяю, истек ли срок действия кеша, а затем решаю, получаю ли я данные из удаленного API или из...

Так, например, у меня есть следующий код: scope.launch { val job = launch { doSomethingHere() } job.join() callOnlyWhenJobAboveIsDone() } Job.join() указано в документации как таковое: Приостанавливает...

Вот моя забава в Repository , которая возвращает мне идентификатор строки из имени группы. @Suppress(“RedundantSuspendModifier”) @WorkerThread suspend fun fetchGroupId(groupName: String): String { return groupDao.fetchGroupId(groupName) }...