если я правильно помню repeat повторяет все что имитилось до этого после он onComplete. У вас onComplete вызывается ?

Может кто подсказать статеечку адекватную на понимание разницы между observable.error(new Exception) и обычного вызова throw new Exception() ? буду благодарен =)

Опиши оба подхода и чекни сорсы

Инстину глаголиш

Всем привет
Помогите с таким кейсом: нужно проверить айтем в базе, если его нет, то полезть в нетворк. Вернуть нужно Flowable
Пробовал:
Flowable.concat(
   getItemFromDatabase(id),
   getItemFromNetwork(id)
)
.first(Item())
.toFlowable()
Возвращает Flowable, но если в бд нашёлся этот айтем и я его изменяю, этот Flowable не реагирует, т.е работает как Single

Если я создаю observable на rxjava, то он начнет испускать события сразу при появлении подписчиков.
Как мне сделать так, чтобы observable вызывал onComplete подписчиков в произвольном месте?

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

а как остановить для всех?

Переформулирую вопрос, как триггерить события в rxJava?

в rxjava просто идут данные, преобразовываясь из одного типа в другой
можно например в flatMap анализировать данные и переделывать их в свои "события",
"статусы" и т.д., пропуская дальше по цепочке
в какую-нибудь функцию обработчик

Через emitter можно, это там где Observable.create(...)

Такой вопрос, если мы хотим часть цепочки обрабатывать одним handler'ом ошибок,
а другую половину цепочки другим handler'ом ошибок, то можно как-то
это сделать в одной цепочке?
пока такого не нашли, делаем старт второй цепочки
если первая запустилась успешно:

               return Completable.fromAction(() -> {
                   Disposable d = someManager.startSomeOperation()
                           ...
                           .flatMapCompletable(status -> checkStatus(status))
// produces Completable.complete()
//or Completable.errror(...)
                           .subscribe(() -> {
                               Disposable d2 = startAnotherOperation(...)
         ...
                                       .observeOn(rxSchedulers.mainThread())
                                       .subscribeOn(rxSchedulers.io())
                                       .subscribe(transactionResult -> {
                                           doSmthOnSuccess(transactionResult);
                                       }, throwable -> AnotherOperationCallback.onFail(throwable));
                           }, throwable -> SomeOperationCallback.onFail(throwable));

ну то есть в идеале где-то в середине поймать исключение в handler
throwable -> { SomeOperationCallback.onFail(throwable)) }
и закончить цепочку, чтобы исключение не проваливалось в handler у метода subscribe

Hi, I'm new to Rxjava... How to fix this

вопрос в чем?

you can just open documentation and sources and read about that. you problem in cast on object without map params, to object with map params

#вопрос. здарствуйте Как я могу сделать?

Видимо только канвасом рисовать, т.е. свой кастомный компонент делать

там скорее всего еще и анимация перехода своя