L
Size: a a a
2020 March 07
2020 March 13
EP
Ребят есть у кого простой пример по RxPm на java
VC
А кто-то из чата использовал на Java. Там были некоторые неудобства вроде, ТК мы либу не хотели захламлять аннотациями для поддержки джавы специально.
2020 March 23
VC
привет, играюсь с семплом rxpm и не могу понять как навигация работает на главном потоке, судя по коду это не возможно но в дебагере handleNavigationMessage всегда на main, можете подсказать в чом суть, может я что-то упустил?
DG
привет, играюсь с семплом rxpm и не могу понять как навигация работает на главном потоке, судя по коду это не возможно но в дебагере handleNavigationMessage всегда на main, можете подсказать в чом суть, может я что-то упустил?
Привет. Навигационные сообщения отправляются через Command, делегаты подписываются на него через bindTo, который и переключает поток на мейн. https://github.com/dmdevgo/RxPM/blob/develop/rxpm/src/main/kotlin/me/dmdev/rxpm/delegate/CommonDelegate.kt#L53
VC
infix fun <T> Command<T>.bindTo(consumer: (T) -> Unit) {
with(pm) {
this@bindTo.observable
.subscribe(consumer)
.untilUnbind()
}
}
вот метод bindTo и там ничего такого нету
with(pm) {
this@bindTo.observable
.subscribe(consumer)
.untilUnbind()
}
}
вот метод bindTo и там ничего такого нету
DG
infix fun <T> Command<T>.bindTo(consumer: (T) -> Unit) {
with(pm) {
this@bindTo.observable
.subscribe(consumer)
.untilUnbind()
}
}
вот метод bindTo и там ничего такого нету
with(pm) {
this@bindTo.observable
.subscribe(consumer)
.untilUnbind()
}
}
вот метод bindTo и там ничего такого нету
Сори, это для стейта, для команды https://github.com/dmdevgo/RxPM/blob/develop/rxpm/src/main/kotlin/me/dmdev/rxpm/PmExtensions.kt#L102
VC
я вот подумал на него, но это как то слишком не очевидно
VC
я сейчас пробую портировать RxPm на Reaktive и когда начал тестировать sample то у меня начало падать, причом не всегда
VC
у меня метод получился таким
internal fun <T> Observable<T>.bufferWhileIdle(
isIdle: Observable<Boolean>,
bufferSize: Int? = null
): Observable<T> {
return this.observeOn(mainScheduler)
.let {
if (bufferSize == 1) {
bufferSingleValueWhileIdle(isIdle)
} else {
bufferValuesWhileIdle(isIdle, bufferSize)
}
}
}
internal fun <T> Observable<T>.bufferWhileIdle(
isIdle: Observable<Boolean>,
bufferSize: Int? = null
): Observable<T> {
return this.observeOn(mainScheduler)
.let {
if (bufferSize == 1) {
bufferSingleValueWhileIdle(isIdle)
} else {
bufferValuesWhileIdle(isIdle, bufferSize)
}
}
}
VC
есть верюятность что где то косяк в реализации буфера но тесты проходят
DG
я вот подумал на него, но это как то слишком не очевидно
В первой версии было в биндту, но потом мы добавили оператор буфера, но он не потокобезопасный, пришлось внутри команды переключать
VC
Ооо, грядет MPP
в итоге хочу получить mpp либу