мммм. Ну, вот у меня есть сабджект, я туда напихиваю онНекстом чего-нибудь и оно там лежит)) И когда я подпишусь, оно всё вываливается. Я хочу, чтобы можно было их оттудова убрать.

но значит тут либо не нужен Rx

либо неверный флоу

опасно такие сабджекты делать

так в остальном всё здорово и выразительно, именно вот этого не хватает

90% случаев с желаниями касательно уничтожения монитора связано именно с этим

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

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

На собеседовании задали вопрос: «Назовите конечные состояния Single?».
О каких состояниях идет речь? Что ответить нужно было?

error / success?

onNext и onError там вроде

да?

Я вопроса не понял, по этому и не ответил на него. Не думал, что речь идет о onSuccess и onError. Спасибо.

Всем привет!
Подскажите, как делать запрос на сервер последовательно, дожидаясь выполнение предыдущего.
Нашел нечто такое, но оно работает паралелно..

        compositeDisposable.add(Observable.fromIterable(listDirector)
            .subscribeOn(Schedulers.single())
            .flatMapCompletable {
                repository.request(AddUser(id!!, syncToken!!, it.id!!, type!!)).onErrorComplete()
            }
            .doAfterTerminate { repository.request(GetRequest(id!!)).subscribe() }
            .subscribe(
                {
                    Log.d(tag,"flatMapCompletable") }
                ,{
                Log.e(tag,"${it.message}")
            }))

        compositeDisposable.add(Observable.fromIterable(listDirector)
            .subscribeOn(Schedulers.single())
            .flatMapCompletable {
                repository.request(AddUser(id!!, syncToken!!, it.id!!, type!!)).onErrorComplete()
            }
            .doAfterTerminate { repository.request(GetRequest(id!!)).subscribe() }
            .subscribe(
                {
                    Log.d(tag,"flatMapCompletable") }
                ,{
                Log.e(tag,"${it.message}")
            }))

concatmap

Думаю не совсем то, список

listDirector

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

flatMap --> concatMap

И там флаг delayError вроде

Или скип еррор

Ну что не станет выполнение