Size: a a a

ReactiveX - русскоговорящее сообщество

2017 March 01

TY

Trubnikov Yaroslav in ReactiveX - русскоговорящее сообщество
Artem Gilmudinov
сек подумаю
Все, решил проблему
источник

TY

Trubnikov Yaroslav in ReactiveX - русскоговорящее сообщество
Надо внутри flatMap заюзать onErrorResumeNext
источник

TY

Trubnikov Yaroslav in ReactiveX - русскоговорящее сообщество
и тогда все норм отрабатывает
источник

TY

Trubnikov Yaroslav in ReactiveX - русскоговорящее сообщество
источник

AG

Artem Gilmudinov in ReactiveX - русскоговорящее сообщество
а что за provideErrors?
источник

TY

Trubnikov Yaroslav in ReactiveX - русскоговорящее сообщество
там я вызываю методы вьюхи, типа показать ошибку и возвращаю Observable с пустой строкой
источник

TY

Trubnikov Yaroslav in ReactiveX - русскоговорящее сообщество
источник

AG

Artem Gilmudinov in ReactiveX - русскоговорящее сообщество
все ясно. можешь для избавления от фильтра возвращать Observable.empty
источник

TY

Trubnikov Yaroslav in ReactiveX - русскоговорящее сообщество
а в фильтре как это отфильтровать? или subscriber его просто не ловит?
источник

AG

Artem Gilmudinov in ReactiveX - русскоговорящее сообщество
а зачем фильтровать?
источник

AG

Artem Gilmudinov in ReactiveX - русскоговорящее сообщество
у тебя в случае ошибки просто не придет
источник

AG

Artem Gilmudinov in ReactiveX - русскоговорящее сообщество
до сабскрайбера
источник

TY

Trubnikov Yaroslav in ReactiveX - русскоговорящее сообщество
ща пробнем, спс
источник

AG

Artem Gilmudinov in ReactiveX - русскоговорящее сообщество
вообще странно
источник

AG

Artem Gilmudinov in ReactiveX - русскоговорящее сообщество
Observable.just(1)
              .doOnUnsubscribe(() -> System.out.println("Unsubscribed 1"))
              .doOnSubscribe(() -> System.out.println("Subscribed 1"))
              .flatMap(i -> Observable.error(new Throwable()))
              .doOnUnsubscribe(() -> System.out.println("Unsubscribe 2"))
              .doOnSubscribe(() -> System.out.println("Subscribed 2"))
              .retryWhen(errors -> errors.take(3).doOnNext(th -> System.out.println(th)))
              .subscribe(printSubscriber);
источник

AG

Artem Gilmudinov in ReactiveX - русскоговорящее сообщество
Subscribed 2
Subscribed 1
Unsubscribe 2
Unsubscribed 1
java.lang.Throwable
Subscribed 2
Subscribed 1
Unsubscribe 2
Unsubscribed 1
java.lang.Throwable
Subscribed 2
Subscribed 1
Unsubscribe 2
Unsubscribed 1
java.lang.Throwable
on completed
источник

AG

Artem Gilmudinov in ReactiveX - русскоговорящее сообщество
то есть видно что он идет до самого корня наверх
источник

AG

Artem Gilmudinov in ReactiveX - русскоговорящее сообщество
хотя понятно
источник

TY

Trubnikov Yaroslav in ReactiveX - русскоговорящее сообщество
@guliashik, подскажи, есть годные примеры работы rxjava + recycler адаптеры? статьи, примеры?
источник

AG

Artem Gilmudinov in ReactiveX - русскоговорящее сообщество
не приходилось пользоваться.
источник