VS
Всем привет, если я создам обсервебл через doonnext до debounce и создам через doonnext после debounce , первый сработает до, в второй после времени, указанного в debounce?
Size: a a a
2020 June 03
i
Всем привет, если я создам обсервебл через doonnext до debounce и создам через doonnext после debounce , первый сработает до, в второй после времени, указанного в debounce?
всегда можно написать тест и посмотреть. Если я правильно понял, то да, должно сработать именно так, как ты написал
2020 June 04
S
Привет!
Подскажите, пожалуйста, у меня два источника стартуют в одно время. Но первым выполняется второй. Как сделать, чтобы они выполнились синхронно? Т.е. сперва первый, а затем только второй
Подскажите, пожалуйста, у меня два источника стартуют в одно время. Но первым выполняется второй. Как сделать, чтобы они выполнились синхронно? Т.е. сперва первый, а затем только второй
DV
Привет!
Подскажите, пожалуйста, у меня два источника стартуют в одно время. Но первым выполняется второй. Как сделать, чтобы они выполнились синхронно? Т.е. сперва первый, а затем только второй
Подскажите, пожалуйста, у меня два источника стартуют в одно время. Но первым выполняется второй. Как сделать, чтобы они выполнились синхронно? Т.е. сперва первый, а затем только второй
Observable.concatArray(
firstSource,
secondSource
)
S
Observable.concatArray(
firstSource,
secondSource
)
А если они зависят от жизненного цикла фрагмента, первый вызывается по onResume, второй по onPause? И вот когда приложение быстро сворачивается, запрос в onPause опережает((
DV
Не пойму. В первом сообщении сказано, что они стартуют в одно время, а теперь один в
onResume, а другой в onPause. Уточни, какую задачу хочешь решить и какие данные в источникахS
Т.е. имел ввиду, что промежуток между их запуском минимален(( Да, неверно выразился, прости(
S
Да, по событиям от фрагмента
S
Т.е. по onPause надо остановить таймер, а по onResume запустить
S
И вот при сворачивании onPause опережает и таймер сначала останавливается, а потом запускается(
DV
Можешь код показать? Как именно запускаешь таймер и стопаешь с помощью Rx
DV
Лучше через Gist
S
Сейчас, к сожалению, нет...( Просто пока мысль идёт только в сторону установки флагов проверки
АК
И вот при сворачивании onPause опережает и таймер сначала останавливается, а потом запускается(
По onPause диспоузни подписку. Если у тебя все в ui потоке то все будет ок и никто никого не опередит
S
А ну ка попробую!!!
S
Спасибо!!!!
2020 June 07
S
fun getItems() {
compositeDisposable?.add(
ApiRequest.service.getItems()
.subscribeOn(iSchedulerProvider.io())
.observeOn(iSchedulerProvider.main())
.subscribe({
viewState.setData(it)
}, ::errors)
)
}Как правильно написать код в rx, чтобы можно было тестить его в unit Тестах?
S
Мне нужно получить элементы из subscribe + тут используется MVP
AD
Singular
fun getItems() {
compositeDisposable?.add(
ApiRequest.service.getItems()
.subscribeOn(iSchedulerProvider.io())
.observeOn(iSchedulerProvider.main())
.subscribe({
viewState.setData(it)
}, ::errors)
)
}Как правильно написать код в rx, чтобы можно было тестить его в unit Тестах?
AD
Singular
fun getItems() {
compositeDisposable?.add(
ApiRequest.service.getItems()
.subscribeOn(iSchedulerProvider.io())
.observeOn(iSchedulerProvider.main())
.subscribe({
viewState.setData(it)
}, ::errors)
)
}Как правильно написать код в rx, чтобы можно было тестить его в unit Тестах?
ApiRequest.service.getItems()
.subscribeOn(iSchedulerProvider.io())
ну и это вынести в отдельное что-то