А
Size: a a a
2017 March 14
AP
вот тот же filter, если через него ничего не проходит то получается empty() ?
А
да. если ни один не удовлетворит условию, то на комплите фильтр просто передаст этот комплит дальше
AP
Observable.just(2)
.filter(x -> x > 3)
.subsrube(.....)
и что будет onCompleted сразу?
.filter(x -> x > 3)
.subsrube(.....)
и что будет onCompleted сразу?
2017 March 15
А
Ну да. Фильтру в onNext приходит айтем, а он его дальше не емитит. После чего срабатывает onComplete, который передается через всю цепочку.
Такие вещи через юныт тесты хорошо проверяются.
Такие вещи через юныт тесты хорошо проверяются.
AP
Ну да. Фильтру в onNext приходит айтем, а он его дальше не емитит. После чего срабатывает onComplete, который передается через всю цепочку.
Такие вещи через юныт тесты хорошо проверяются.
Такие вещи через юныт тесты хорошо проверяются.
окей, а если после фильтра еще операторы? то они уже не выполнятся?
AP
Observable.just(2)
.filter(x -> x > 3)
.flatMap(...)
.subsrube(.....)
.filter(x -> x > 3)
.flatMap(...)
.subsrube(.....)
AP
flatMap не будет исполнен?
AP
вот такие тонкости не описаны в доке, а вместо этого дали нам какие-то ребусы, которыфми не все операторы достаточно понятно описаны
А
так если данных нету, то и выполнять нечего.
удобно, например, для валидации. если пользователь передал невалидные данные, то и на бекенд их не шлем
удобно, например, для валидации. если пользователь передал невалидные данные, то и на бекенд их не шлем
А
вот такие тонкости не описаны в доке, а вместо этого дали нам какие-то ребусы, которыфми не все операторы достаточно понятно описаны
Да ладно, там еще нормальная дока. Да и в марблах не так сложно разобраться.
AP
а вот еще мне иногда удобнее собрать все эммиты в список, делаю toList()
AP
ну по марблам я не все операторы смог понять(
AP
например я не понял разницу между zip, concat, merge
AP
которые статик методы
AP
обсервабла
А
concat и merge похожие - объеденяют несколько потоков в один, просто передавая данные дальше по потоку. Разница в том, что первый делает это в порядке добавленных потоков, а второй в порядке появления данных.
zip же комбинирует айтемы с разных потоков в какой-то другой айтем.
zip же комбинирует айтемы с разных потоков в какой-то другой айтем.
A
Есть RxJava2 and Retrofit 2.2.0 необходимо добавить RxErrorHandler что бы можно было бы достать при ошибке 40x json с body ответа. Может есть у кого хороший пример?
A
Кто то же делал обработку ошибок с Retrofit 2.2.0 )
А
Есть пример