крутяк!

@dmdev тогда тебе точно нужно обратить внимание на StateFlow https://github.com/Kotlin/kotlinx.coroutines/issues/1973

fun <T> StateFlow(value: T): MutableStateFlow<T>

Вот это очень смущает именование. Функция-конструктор с именем имутабельного StateFlow, a создаёт мутабельный MutableStateFlow...
Ну такое....

Подождём, когда финализируют)

Еще пол года будем ждать EventFlow)

Оно теперь так называться будет?)

Мы так-то вроде никуда не торопимся, пусть делают))

Там кстати в комментах норм навалили про это 😁

Ага, молодцы)

UPDATE: Based on your feedback we've decided to rename StateFlow() constructor to MutableStableFlow() and to fast-track all the core StateFlow APIs to stabilization.

Собственно, вот)

Видели?

#RxJava

Rx головного мозга

Команда Android-разработки FunCorp вдохновилась докладом Jake Wharton и решила попробовать написать приложение полностью построенное на Rx. Даже так, где это кажется очень странным, сильно упрощает жизнь и делает код очевиднее.

Так ли это или нет можете почитать в разборе этого подхода в статье.

😁 Погнали комментарий Димы плюсовать: https://m.habr.com/ru/company/funcorp/blog/500980/comments/#comment_21609882

Привет, где можно найти инструкцию по миграции на вторую версию библиотеки?

Прям инструкции нет. Но можно глянуть что менялось в релизах https://github.com/dmdevgo/RxPM/releases

Спасибо

привет, возникла ситуация при работе с action и retry
есть вот такой action, я хочу чтоб он начал загрузку когда pm будет создана, добавил startWithValue(Unit)
но в случае ошибки получил цикл что вроде как логично так как цепочка начинаеться с startWithValue(Unit) после ошибки она заново переподпишеться и все по кругу
вопрос в том можно ли как то запустить action когда pm будет создана и не уйти в цикл и не писать отдельную подписку на lifecycle:

val onCreate = action<Unit>{
   lifecycleObservable
       .filter { it == Lifecycle.CREATED }
       .take(1)
       .doOnBeforeNext { loadAction.accept(Unit) }
}

val loadAction = action<Unit> {
       startWithValue(Unit)
           .flatMapSingle {
               categoryInteractor.getPopularCategories()
                   .doOnBeforeSuccess(dataConsumer)
                   .doOnBeforeError(errorConsumer)
           }
   }

спасибо

Привет. А так?

   override fun onCreate() {
       super.onCreate()
       loadAction.accept(Unit)
   }

так не работает, видимо по тому что action еще не подписан когда oncreate отработал