AD
зависит от того, что конкретно «мапить исключения» подразумевает
Size: a a a
2020 March 21
DT
допускаю, что можно просто через throw кинуть
да, кажется это идеально! спасибо!
2020 March 22
DT
Привет. Подскажите пожалуйста, как работать с onErrorReturn после оператора zip. Ругается при сборке:
Type inference failed: Not enough information to infer parameter R in fun <T1 : Any!, T2 : Any!, T3 : Any!, R : Any!>
DT
если без onErrorReturn то возвращает CompositeException. Как это дело обработать после zip?
AD
Привет. Подскажите пожалуйста, как работать с onErrorReturn после оператора zip. Ругается при сборке:
Type inference failed: Not enough information to infer parameter R in fun <T1 : Any!, T2 : Any!, T3 : Any!, R : Any!>
думаю, нужен RxKotlin, который лечит эту беду
i
если без onErrorReturn то возвращает CompositeException. Как это дело обработать после zip?
Проставляй явно дженерик тайпы
2020 March 23
v
когда используешь fromIterable, элементы начинают асинхронно чтоли обрабатываться? О_О
АК
когда используешь fromIterable, элементы начинают асинхронно чтоли обрабатываться? О_О
по дефолту Rx синхронный. Все зависит что ты делаешь дальше.
если просто doOnNext и лог то все будут последовательно.
если просто doOnNext и лог то все будут последовательно.
v
что-то у меня совсем моск поплыл. Я вот тоже думаю, что, вроде, синхронно, но с какого-то момента оно начинает следующий элемент дёргать, когда, вроде бы, пайплайн из флетмапов до конца не дошёл...
АК
что-то у меня совсем моск поплыл. Я вот тоже думаю, что, вроде, синхронно, но с какого-то момента оно начинает следующий элемент дёргать, когда, вроде бы, пайплайн из флетмапов до конца не дошёл...
вооот и ответ “флетмапов” )
v
вооот и ответ “флетмапов” )
мммм, а что не так?)
v
постоянно бывают моменты, когда кажется "всё, вот теперь я точно расставил все точки над "и" в этом адовом фреймворке, а потом меня какая-то такая фигня спускает с небес на землю)))
АК
ну попробуй к примеру такой код:
Observable.fromIterable(List.of(1,2,3,4,5))
.flatMapSingle(integer -> Single.timer(new Random(1000L).nextLong(), TimeUnit.MILLISECONDS)
.map(aLong -> integer))
.doOnNext(number -> System.out.println(number));
Что-то типо того
Observable.fromIterable(List.of(1,2,3,4,5))
.flatMapSingle(integer -> Single.timer(new Random(1000L).nextLong(), TimeUnit.MILLISECONDS)
.map(aLong -> integer))
.doOnNext(number -> System.out.println(number));
Что-то типо того
АК
По сути в этом случае все придут в флетмап, потом перейдут на компутейшн потоки и кто первый выплюнулся тот и красавчик
АК
и по итогу ты на выход не гарантируешь 1 2 3 4 5
v
спасибо, буду думать
АК
постоянно бывают моменты, когда кажется "всё, вот теперь я точно расставил все точки над "и" в этом адовом фреймворке, а потом меня какая-то такая фигня спускает с небес на землю)))
я так уже 4ый год живу)
В этом чатике меня раз 10 уже утыкали)
В этом чатике меня раз 10 уже утыкали)
v
я только полтора года использую ырыкс, до этого год просто читал про него :D
K
Привет!
Я запускаю поток -> возращается Success -> обновляю UI и делаю встплывающее окно что успешно все прошло.
Когда делаю второй раз нужно только обновить UI без всплывающего окна
Вопрос: как сделать в rxjava так чтобы в первый раз она сделала 1+2 действие а второй раз только 1 действие
Я запускаю поток -> возращается Success -> обновляю UI и делаю встплывающее окно что успешно все прошло.
Когда делаю второй раз нужно только обновить UI без всплывающего окна
Вопрос: как сделать в rxjava так чтобы в первый раз она сделала 1+2 действие а второй раз только 1 действие
i
спасибо, буду думать
а что думать? Надо просто посмотреть, чем отличаются flatMap, concatMap, switchMap. У каждого есть своё применение