Телеграмм чат группы kotlin

inline fun <T> Flow<T>.collectLifecycle(lifecycleOwner: LifecycleOwner, crossinline block: (T) -> Unit) {
    lifecycleOwner.lifecycleScope.launchWhenStarted {
        collect { block.invoke(it) }
    }
}

Коллектинг флоу суспендится, если будет onStop, и когда пользователь вернётся - коллектинг зарезьюмится. Проблема в том, что если в этом промежутке было много новых ивентов, то они вывалятся пачкой, а мне надо взять только последнее. Добавление conflate() не помогает, помогло debounce(10), но это не подходящее решение, надо без дебаунса. Есть идеи?

источник

12:55пожаловаться #14

Igor in Kotlin Community

Кирилл Романенко

Подскажите, пожалуйста, как лучше обойти проблему.
Здесь отчасти замешан андроид, но вопрос именно про флоу.

inline fun <T> Flow<T>.collectLifecycle(lifecycleOwner: LifecycleOwner, crossinline block: (T) -> Unit) {
    lifecycleOwner.lifecycleScope.launchWhenStarted {
        collect { block.invoke(it) }
    }
}

А какой у этого flow источник?

источник

12:59пожаловаться #15

КР

Кирилл Романенко... in Kotlin Community

Igor

А какой у этого flow источник?

StateFlow, который потом маппится на обычный флоу. В этот стейт флоу может быть в этом промежутке записано достаточно много ивентов, надо взять последнее.

источник

13:00пожаловаться #16

Igor in Kotlin Community

И почему кстати onEach, а не collect?

источник

13:00пожаловаться #17

КР

Кирилл Романенко... in Kotlin Community

Igor

И почему кстати onEach, а не collect?

Да без разницы

источник

13:01пожаловаться #18

Eugene P. in Kotlin Community

Какой каноничный способ организовать очередь для доступа/редактирования данных в многопоточной среде чтобы исключить параллельный доступ к данным? Один из вариантов это использовать Mutex для блокировки, Но в документации нашел пример на акторах. Есть ли способ шарить актор между разными методами? Пример, как тут правильно реализовать функцию sendMessage

источник

13:12пожаловаться #19

Eugene P. in Kotlin Community

class UserDao {
    // in-memory cache of the user object
    var user: User = User("", "")
        private set

    suspend fun getUser(): User {
        val response = CompletableDeferred<User>()
        sendMessage(UserMsg.GetUser(response))
        return response.await()
    }

    suspend fun setUser(user: User) {
        sendMessage(UserMsg.SetUser(user))
    }

    private suspend fun sendMessage(msg: UserMsg) {
        when (msg) {
            is UserMsg.SetUser -> user = msg.user
            is UserMsg.GetUser -> msg.response.complete(user)
        }
    }

    sealed class UserMsg {
        class SetUser(val user: User) : UserMsg() // one-way message to set user
        class GetUser(val response: CompletableDeferred<User>) : UserMsg() // a request with reply
    }
}

источник

13:13пожаловаться #20