l
хотя по примеру можно через onErrorReturn, но я бы не оборачивал. мало ли оно мимо пролетит
Size: a a a
2020 December 14
A
хотя по примеру можно через onErrorReturn, но я бы не оборачивал. мало ли оно мимо пролетит
Просто в случае onErrorReturn всё равно вернется ошибка, но то что обработка на стороне сабскрайбера - кажется это не так и плохо 😅
S
single.onErrorResumeNext(thr -> thr instanceof IoException ? Single.error : Single.just)Вааах!!! Все отрабатывает нормально, спасибо большое))
S
А еще вопрос из той же серии, если мне пришел определенный элемент в Single, как мне вернуть по нему ошибку?
Я сейчас делаю так:
в map или doOnSuccess проверяю, какой элемент, если тот, что нужен, то делаю
thow new RightException(...)
Я сейчас делаю так:
в map или doOnSuccess проверяю, какой элемент, если тот, что нужен, то делаю
thow new RightException(...)
S
Может здесь тоже есть более подходящий подход с заворачиванием в Single?
S
Просто в случае onErrorReturn всё равно вернется ошибка, но то что обработка на стороне сабскрайбера - кажется это не так и плохо 😅
Только тут остается момент, как правильно прокидывать сам throwable(( Делал как throw new Exception(throwable)
l
А еще вопрос из той же серии, если мне пришел определенный элемент в Single, как мне вернуть по нему ошибку?
Я сейчас делаю так:
в map или doOnSuccess проверяю, какой элемент, если тот, что нужен, то делаю
thow new RightException(...)
Я сейчас делаю так:
в map или doOnSuccess проверяю, какой элемент, если тот, что нужен, то делаю
thow new RightException(...)
flatmap(v -> if predicate.test(v) ? just/error : just/error)l
ошибки надо оборачивать в поток. иначе может случиться что ошибка пойдет не в потоке например
S
S
ошибки надо оборачивать в поток. иначе может случиться что ошибка пойдет не в потоке например
Т.е. всегда следует оборачивать в Single, Maybе, Observable и т.д.? Где-то может случится кейс, что делаем throw ... и приложение падает
l
Т.е. всегда следует оборачивать в Single, Maybе, Observable и т.д.? Где-то может случится кейс, что делаем throw ... и приложение падает
ну по крайней мере люди пишут что на некоторых операторах так бывало. баг ли это в каких-то операторах или логика какая я до конца не разбирался
S
ну по крайней мере люди пишут что на некоторых операторах так бывало. баг ли это в каких-то операторах или логика какая я до конца не разбирался
Принял во внимание ☝️
2020 December 28
I
Привет.
Такой вопрос. Вот заэмитил flowable, в цепочке есть много операторов. Может быть такое, что для одного эмита еще не выполнилась вся цепь, но она уже начала выполняться для другого?
Такой вопрос. Вот заэмитил flowable, в цепочке есть много операторов. Может быть такое, что для одного эмита еще не выполнилась вся цепь, но она уже начала выполняться для другого?
flowable
.map {
если для предыдущего эмита не
выполнилось тело этого оператора?
*тут что-то тяжелое*
}
..
.flatMap {
Могу ли я оказаться здесь
при следующем эмите,
}M
Привет.
Такой вопрос. Вот заэмитил flowable, в цепочке есть много операторов. Может быть такое, что для одного эмита еще не выполнилась вся цепь, но она уже начала выполняться для другого?
Такой вопрос. Вот заэмитил flowable, в цепочке есть много операторов. Может быть такое, что для одного эмита еще не выполнилась вся цепь, но она уже начала выполняться для другого?
flowable
.map {
если для предыдущего эмита не
выполнилось тело этого оператора?
*тут что-то тяжелое*
}
..
.flatMap {
Могу ли я оказаться здесь
при следующем эмите,
}да, flatMap асинхронный оператор
I
да, flatMap асинхронный оператор
Спасибо, а если подписываться в Schedulers.single()? Без разницы?
M
Спасибо, а если подписываться в Schedulers.single()? Без разницы?
насчет schedulers не подскажу, я на rxjs пишу
M
Спасибо, а если подписываться в Schedulers.single()? Без разницы?
если хотите сохранить порядок используйте concatMap
I
если хотите сохранить порядок используйте concatMap
Тогда сoncatMap никогда не выполнится раньше map, который выше в цепи?
M
concatMap получает входящий обсервебл, подписывается на него и эмитит все его значения, затем подписывается на следующий входящий обсервебл
2020 December 29
I
concatMap получает входящий обсервебл, подписывается на него и эмитит все его значения, затем подписывается на следующий входящий обсервебл
спасибо, я вот думаю, что Schedulers.single() должен решать эту проблему, так как он даёт гарантию, что все операторы выполнятся в одном потоке