Или просто обсервер перестает их получать

Насколько я понял observable перестаёт генерировать значение когда возникает onCompleted и когда observer отписывается. При условии если это cold Observable.

С onCompleted понятно, а вот если просто отписаться то несовсем

Надо попробовать отписаться и снова подписаться)

Если у тебя Cold observable то получать значение будешь с первого элемента.

В 4 уроке все это описывается.

Ага, я просто пока на 3

Буду дальше читать

Cold должен перестать постить значения

Hot продолжит и после unsubscribe

вы можете для Observable добавить оператор doOnNext

он будет срабатывать при отправке элементов

Значит я внимательно читал уроки...)))

))

😀😀😀

Привет. Есть вопрос.

У меня есть клас LoginValidator, который возвращяет 1 из 3 колбеков:
errorEmai(),
errorPassword(),
valid().

Возможно ли вообще эти колбеки возвращять с rxJava/Android на рядку с onComplete, onError?
Или же LoginValidator нужно переписывать, чтобы он возвращал какой то цифровой идентификатор/enum, для каждой ошибки?
Вобщем, в каком направлении искать?

мне кажется, что оборачивать это в Rx получится сложнее, чем колбэки оставить

Я понимаю, сам по себе LoginValidator слишком простой, чтобы к нему применять rx.
ПРоблема у меня более общая. Проект написан на MVP. Presenter обычно делает один запрос в Interactor, а тот в свою очередь возвращает один из нескольких колбеков.
Хотелось использовать rx чтобы интеракторы работали в другом потоке и возкращали нужное значение или ошибку в presenter. Но уперса в то в большое количество колбеков..

Например, LoginPresenter пингает метод login каласа LoginInteractor. Интерактор, если данные валидные, логирует юзера.
И возвращает, к примеру, emailError, passwordError, loginSuccess, requestError.

Запрос к серверу можно обернуть в Rx, хотя бы для того, чтобы потоки удобно разрулить

Обычно парадигма запросов к серверу подразумевает только два колбэка - success и error

error - это когда сетевые проблемы, или сервер не отвечает (т.е. вполне подходит как onError в Rx)
если же сервер ответил, то его ответ идет в success (onNext в Rx) и там уже по содержимому ответа определяется дальнейшая логика

Так, например, работает Retrofit. Я о нем коротко рассказывал в Уроке 9 курса RxJava