Ну а где отписаться, в onSuccess? Там как-то странно смотрится

Ну типа отписка в onDestroy делается обычно

В репе нет ондестрой

Намути эту штуку с диспосибл в презентере, а тут убери

Или какая у тебя связка?

Или какая у тебя связка?

Да, такая

Вью > Презентер > Репа

Ну а вообще вот идея. Не знаю правильно нет. Вью вызывает ондестрой , ты вызываешь метод презентера , который дёргает репу и отписывается

Да, наверное так и надо сделать

Работать точно будет

А вообще очень крутая связки с use case

Тоесть к репозиторию ещё и юзкейс добавляется

В итоге получается клин

Только вопрос как к CompositeDisposable теперь доступ из репы получить. Не тащить же за собой :/ А публичным делать ну тоже как-то что-то не то

Не понял.

У тебя запрос в репозитори.

Ну если CompositeDisposable теперь будет во вью

Нет.

Ты не понимаешь немного)))

Для чего он тебе нужен?) Это композит?

Для чего он тебе нужен?) Это композит?

Чтобы отписаться)

А зачем подписываться

А зачем подписываться

Студия так хочет.

Сек

Ну вот я тебе говорю тогда.

Создай метод в репозитории

Назови его destroy

В нем напиши dispose

И вызывай его в презентере , а презентер вызывай когда ондестрой во вью

Понимаешь?

Создай метод в презентере и в репозитории

тогда обратно тащить композит придется

В репе диспоз делай, в презентере просто дергай, во Вью дергай презентер

из репы в презнтер из презентера во вью

Нет.

Ты из фрагмента или активности вызываешь презентер

А презентер вызывает репу

У тебя так работает?

из активности

Вью > Презентер > Репа

и назад

А тащить зачем что-то

Обратно ничего не надо !

ну а как я отпишусь? чтобы отписаться надо же к композиту обратиться. а если он у нас в репе?

В репе обратись.

Отписка в репе!!!!

Отписка должна быть в репозитории. Просто этот метод вызывается в презентере. А метод презентера во Вью. Всё.

а, то есть в ондестрое бежать до репы и отписываться :/

Отписка должна быть в репозитории. Просто этот метод вызывается в презентере. А метод презентера во Вью. Всё.

а ты сам как делаешь?)

Я тебе 10 минут об этом говорю.

а, то есть в ондестрое бежать до репы и отписываться :/

По хорошему есть юзкейс и есть репозиторий

Но к этому нужно прийти самому

Поэтому изучай рх, пробуй, пытайся

а, то есть в ондестрое бежать до репы и отписываться :/

Используй, пожалуйста, ответы.

ну а как я отпишусь? чтобы отписаться надо же к композиту обратиться. а если он у нас в репе?

Возвращай из репы обзёрвабл. У кого жизненный цикл — тот и отписывается.

Возвращай из репы обзёрвабл. У кого жизненный цикл — тот и отписывается.

обсервбл?

я же обсервбл в репе обрабатываю

я же обсервбл в репе обрабатываю

Я и говорю, не надо так

Я и говорю, не надо так

так вот такого рода штуки в репе же должны быть. или где? ://

Используй java.util.concurrent.Future

Будет mBackToTheFuture.

Извините

😁

так вот такого рода штуки в репе же должны быть. или где? ://

Нет

Подписки там где и отписки

В презентере

чего? презентер это только посредник. он вообще ничего не делает кроме как адресует.. чего я не понимаю?

🤔

Репо не должно знать о презентере

Ты из репо тянешь шланг, в который в презентере втыкаешь форсунку

Репо не должно знать о презентере

ну с помощью даггера можно сделать было, да

Нет, можно было сделать без даггера руками

чего? презентер это только посредник. он вообще ничего не делает кроме как адресует.. чего я не понимаю?

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

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

Возвращай из репы обзёрвабл. У кого жизненный цикл — тот и отписывается.

Отличное решение.

ну чтобы стянуть данные нужен вот такой код, правильно? mApiRandomUser.getRandomUsers(ApiRandomUser.USERS_PER_PAGE) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .map(new Function<ListUsersResponse, List<User>>() { @Override public List<User> apply(ListUsersResponse listUsersResponse) throws Exception { return getUsers(listUsersResponse.getResults()); } }) .subscribe(new Consumer<List<User>>() { @Override public void accept(List<User> users) throws Exception { mBackToPresenter.inflateUsers(users); } }, new Consumer<Throwable>() { @Override public void accept(Throwable throwable) throws Exception { Log.d("devptag", "accept: "); } });

так репа же стягивает. а как иначе я это оберну, я не совсем понимаю

так репа же стягивает. а как иначе я это оберну, я не совсем понимаю

Унеси subscribe из репы уже

Не там подписываешься