возвращай елемент onNext

Мне нужно чтоб onComplete() не был выполнен

так у тебя либо onComplere() либо onError() в Single

другого не дано

Вообще таск такой: Выполнить метод. Если успешно, сделать *что-то*, если с ошибкой, то ничего

Single.error(new RuntimeException("Все очень плохо"))

Я подписан так: observable.doAfterSuccess { notificationManager.notify(NOTIFICATION_ID, notificationRepository.getNotification(notificationModel)) }

ты вообще перехватываешь ошибки гденибудь?

Нет

Говорюже

Мне надо заигнорить

Выполнить метод. Если успешно, сделать *что-то*, если с ошибкой, то ничего

ну так подпишись двойным response , throwable

Типо?

ничего = v -> {}

просто пустая лямбда

Вот целиком как?

observable.doOnSucsess?

doOnSubscibe

нет

Подскажите вакансий для JS программиста, то есть чат где искать таких прогеров

подписка с 2 параметрами

subscribe ({v -> OK} , {v -> -> NOTOK} )

только вместо скобок имя переменной

subscribe ({v -> OK} , {v -> -> NOTOK} )

Я так не могу сделать

казал же

Сказал же

почему

ага, почему?)

Мне надо это обработать на уровне самого формирования Observable

сложно, код в студию

Ладно. Пошел на уступки перед архитектурой

Будут две фигурные скобки

Мне надо это обработать на уровне самого формирования Observable

а кто диктует такие условия?

Я и чистая архитектура

Но я больше

а что это за архитектура такая?

Ну четкое разделение по слоям

Мы формируем observable

в чистой архитектуре про рх вообще ни слова, рх это конретная реализация

И в другом месте просто вызываем выполнение

обрабатывать ошибки можно на любом из слоев

Ладно. Убедил

если ошибка происходит в обсервере - он ее и пробросит, тут все чисто вроде бы

в любом случае подписчик всегда должен ловить ошибки, чтобы не кидать сюрпризы

не надо оборачивать его еще выше

можно ловить onErrorResumeNext для обработки специфичных для слоя ошибок

и передавать дальше в другом формате

Убедил. Спасибо

подписчик ловит все то, что не словили другие слои до него

да и обычно подписчик это презентер, а он и общается с "вью". В любом случае он будет отдавать команды по отображению ошибок юзеру

мне больше не нравиться мой вариант, у меня в онНекст может прийти 200 (Ретрофит + Rx), но при этом это может быть плохой респонс, со статусов error, вот как это решать?

Ну так у ретрофита есть Response<твоя сущность> . у респонса можно получить код, мессадж и боди

я в репозитории проверяю модельку от сервера, и если не "ок" то делаю Single.error кастомная ошибка, как правило, там стринга от сервера

во-во

был даже вопрос на СО https://ru.stackoverflow.com/questions/683503/%D0%9A%D0%B0%D0%BA-%D1%80%D0%B5%D1%88%D0%B8%D1%82%D1%8C-%D0%BF%D1%80%D0%BE%D0%B1%D0%BB%D0%B5%D0%BC%D1%83-%D0%BB%D0%BE%D0%B2%D0%BB%D0%B8-%D0%BE%D1%88%D0%B8%D0%B1%D0%BE%D0%BA-%D0%B2-%D0%A7%D0%B8%D1%81%D1%82%D0%BE%D0%B9-%D0%90%D1%80%D1%85%D0%B8%D1%82%D0%B5%D0%BA%D1%82%D1%83%D1%80%D0%B5/683552#683552

хм, еще раз.. я думал сделать какуето прослойку в doOnNext() и там смотреть на статус и если статус не ок - ошибку кидать

Тогда уж map Response<твоя сущность> в твою сущность

по-мойму doOnnext не дружит с подпиской, типа взаимоисключающие

юзай .map

wut?

точне с доОнЕррор

когда оба нужны

то я перепутал

есть там кароче камень подводный

не встречал, что бы что-то с подпиской не дружило. Пример в студию

ERROR: S client not available

.doOnNext { if (it.error != null) { throw Exceptions.propagate(IllegalStateException(it.error)) } } .toList() .doFinally { stopProgress() } .subscribe({

или .subscribe { if (it.status == DefaultResponse.EStatus.ok) formModel = builder.buildExtraFieldsForm(it.data, holder) }

не встречал, что бы что-то с подпиской не дружило. Пример в студию

я про doOnError + doOnNext, с подписками норм все, да

потому что ретрофит дергает onNext() если 200 статус и onError когда статус != 200

у меня может быть статус 200, но запрос не прошел на сервере и пришла ошибка

тогда сервер должен дополнительно свой статус присылать

полем

так он есть в теле ответе, как доп поле

вопрос в том, на каком этапе его проверять

ну в таком варианте .map норм

и можно ли написать универстальную опертаку для всего нетворк адаптера

а че меп? что тут мепить?

if (response.isSuccess()) { return response; } else { throw ... }

возвращаешь аргумент, и получается, что ничего не мапил, но свой код вставил

ну да, это как я сделал .doOnNext { if (it.error != null) { throw Exceptions.propagate(IllegalStateException(it.error)) } } не вижу разницы\преймущества в меп, просто тоже как вариант

входящий тип = возващаемому

это ты про какой случай?

если не юзать doOnError + doOnNext, то отличий нет

я понял

Всем привет. Кто-нибудь в курсе, почему Retrofit может не посылать по своему желанию запрос на сервер? То есть каким-то образом эмулировать запрос, как бы глупо это не звучало) С сервера при реальном обращении приходит gzip. Логика не ломается, так как по-любому результат запроса попадает в onResponse, вне зависимости запрос на сервер прошел или нет. Может есть какой-то кэшинг относительно gzip в retrofite?

а если логи посмотреть?

bitbucket упал

а если логи посмотреть?

Никаким образом не могу отследить. Это происходить рандомно вообще. Отправил около тысячи запросов, все норм прошло. Но проблема есть

Может есть какой-то кэшинг относительно gzip в retrofite?

есть

непомню или включен по умолчанию, но вполне может быть если сервер поддерживает

вот мой хэдер, который приходит на ответ

если чем поможет

"headers":{"namesAndValues":["Server","nginx","Date","Mon, 03 Jul 2017 15:26:06 GMT","Content-Type","application/json","Content-Length","1662","Connection","keep-alive","X-Powered-By","PHP/5.4.42","Pragma","no-cache","Expires","Mon, 03 Jul 2017 15:26:11 GMT","Vary","Accept-Encoding","Content-Encoding","gzip"]

Здравствуйте, я на днях решил начать изучать язык JAVA. У меня вот такой вопрос : уместен ли будет этот язык для разработки игр под операционную систему Android, или есть всё-же более пригодный другой вариант, нежели изучение JAVA?

вроде джавовые движки не оч популярны сейчас

С# unity