i
Как и onBackpressureBuffer
Size: a a a
2020 August 03
i
Но именно после первой функции тебе нужно ждать
В
если сделать concatMapDelayError и убрать onBackpressureBuffer, то все работает
В
интересно что поломалось теперь
i
Ну вообще звучит логично, смотри реализацию concatMapDelayError
i
Думаю там ответ
i
Откуда у тебя бэкпрешшур, если все элементы обрабатываются последовательно?
В
getUpdatesPack это стрим с сервера, первым элементом приходит пак на 100500 апдейтов, а потом по мере поступления
В
и по идее они могут приходить быстрее чем их обрабатывает приложение, вроде backpressure про это
i
Я думаю решение должно быть таким, сейчас проверю
i
Хм, интересно
В
сработало?
i
Только не flatMapMaybe, а concatMapMaybe
i
в первом случае flatMap заменяется на concatMapDelayError по двум причинам
1) flatMap распараллеливает твои эмиты, а значит если их будет больше одного, то твоя цепочка сломается (backpressure), нужен concatMap
2) откладывать ошибку нужно там же, где она прилетает
1) flatMap распараллеливает твои эмиты, а значит если их будет больше одного, то твоя цепочка сломается (backpressure), нужен concatMap
2) откладывать ошибку нужно там же, где она прилетает
i
Остальное, я думаю понятно
В
спасибо, попробую разобраться
В
ты перенес doonnext внутрь contactMapDelayERror потому что вовне приходит сразу error ?
i
каждый элемент мы раскладываем на составляющие, и делаем concatMapMaybe, чтобы они выполнялись последовательно