I
так а в чем проблема корутин?
Size: a a a
2020 February 12
mP
Возможно я не до конца понимаю как правильно запускать работу и переключаться между потоками
mP
Именно как это написать
I
1) не похоже, что reportsInteractor.getReports асинхронный
2) если долго выполняется, смотрите внутрь reportsInteractor.getReports, причем тут корутины?
2) если долго выполняется, смотрите внутрь reportsInteractor.getReports, причем тут корутины?
mP
reportsInteractor.getReports - suspend функция, использующая ретрофит
mP
1) не похоже, что reportsInteractor.getReports асинхронный
2) если долго выполняется, смотрите внутрь reportsInteractor.getReports, причем тут корутины?
2) если долго выполняется, смотрите внутрь reportsInteractor.getReports, причем тут корутины?
потому что ощущение что долго переключается между потоками, потому что запрос я кеширую и должно все выполнятся быстро при повторных вызовах
mP
и выполнялось, пока я CoroutineScope не перенес в presenter
mP
до этого во view делал
DE
CoroutineScope(Dispatchers.Main).launch {
view?.showChartsLoadBars()
withContext(Dispatchers.IO) {
val reportsResult = reportsInteractor.getReports(generalTimeRange, step)
withContext(Dispatchers.Main) {
if (reportsResult is AppResult.Success) {
val reports = reportsResult.value
updatePoints(currentReport, reports)
} else {
showError(reportsResult as AppResult.Error)
}
view?.hideChartsLoadBars()
}
}
}
где reportsInteractor.getReports(generalTimeRange, step) - проиходит асинхронщина. Но че то долго
view?.showChartsLoadBars()
withContext(Dispatchers.IO) {
val reportsResult = reportsInteractor.getReports(generalTimeRange, step)
withContext(Dispatchers.Main) {
if (reportsResult is AppResult.Success) {
val reports = reportsResult.value
updatePoints(currentReport, reports)
} else {
showError(reportsResult as AppResult.Error)
}
view?.hideChartsLoadBars()
}
}
}
где reportsInteractor.getReports(generalTimeRange, step) - проиходит асинхронщина. Но че то долго
1. Нигде не хранишь скоуп. А если надо отменить корутину?
2. view?.something(). Если ты не кэшируешь результат запроса, то стоит ли вообще его делать, если view == null?
3. withContext(IO) не нужен, так как у okHttp свой ExecutorService.
4. Напрашивается when() на разбор ответ AppResult
2. view?.something(). Если ты не кэшируешь результат запроса, то стоит ли вообще его делать, если view == null?
3. withContext(IO) не нужен, так как у okHttp свой ExecutorService.
4. Напрашивается when() на разбор ответ AppResult
mP
1. Нигде не хранишь скоуп. А если надо отменить корутину?
2. view?.something(). Если ты не кэшируешь результат запроса, то стоит ли вообще его делать, если view == null?
3. withContext(IO) не нужен, так как у okHttp свой ExecutorService.
4. Напрашивается when() на разбор ответ AppResult
2. view?.something(). Если ты не кэшируешь результат запроса, то стоит ли вообще его делать, если view == null?
3. withContext(IO) не нужен, так как у okHttp свой ExecutorService.
4. Напрашивается when() на разбор ответ AppResult
1 - потом решил это сделать
2 - кэширую, но последнее не понял
3 - не знал, спасибо
4 - в базовой вью все разбирается
2 - кэширую, но последнее не понял
3 - не знал, спасибо
4 - в базовой вью все разбирается
ВС
Подскажите пожалуйста как организовать проверку runtime permissions в чистой архитектуре?
МE
Brakepoint наверно срабатывает на сам вызов оператора toList. Но сам toList будет ждать, пока upstream завершится с onComplete или onError.
копнул дальше, onComplete всё же вызывается:
if (!d.isDisposed()) {
if (v == null) {
observer.onComplete();
} else {
observer.onSuccess(v);
}
}
получается без OnNext цепочка прерывается?
как-то всё криво в room+rx
if (!d.isDisposed()) {
if (v == null) {
observer.onComplete();
} else {
observer.onSuccess(v);
}
}
получается без OnNext цепочка прерывается?
как-то всё криво в room+rx
AI
копнул дальше, onComplete всё же вызывается:
if (!d.isDisposed()) {
if (v == null) {
observer.onComplete();
} else {
observer.onSuccess(v);
}
}
получается без OnNext цепочка прерывается?
как-то всё криво в room+rx
if (!d.isDisposed()) {
if (v == null) {
observer.onComplete();
} else {
observer.onSuccess(v);
}
}
получается без OnNext цепочка прерывается?
как-то всё криво в room+rx
Поставьте doOnComplete сразу после geByUniqueId, если сработает, значит в другом проблема, если нет, значит поток не завершается. Вообще если это observable, то это нормально, room будет обновлять о поступлении данных. Используйте Maybe
МE
Поставьте doOnComplete сразу после geByUniqueId, если сработает, значит в другом проблема, если нет, значит поток не завершается. Вообще если это observable, то это нормально, room будет обновлять о поступлении данных. Используйте Maybe
В общем Maybe и doOnComplete помогло, продвинулся дальше) спасибо
А
Не подскажете как в MVI обрабатывать вложенные стейты ? Есть родительский фрагмент и два вложенных фрагмента, действия в одном фрагменте могут влиять на стейт других
AD
Не подскажете как в MVI обрабатывать вложенные стейты ? Есть родительский фрагмент и два вложенных фрагмента, действия в одном фрагменте могут влиять на стейт других
AD
Не подскажете как в MVI обрабатывать вложенные стейты ? Есть родительский фрагмент и два вложенных фрагмента, действия в одном фрагменте могут влиять на стейт других
ваще это лучше
AI
Не подскажете как в MVI обрабатывать вложенные стейты ? Есть родительский фрагмент и два вложенных фрагмента, действия в одном фрагменте могут влиять на стейт других
Не делать сложных вложенных состояний?
AD
а если это нужно?)