Вы на берегу договариваетесь, что например лента новостей иммутабельна

И еееесли что то поменяется то тебе пришлется нотификейшн

Так вот, об этом я и говорю. А если нашли в БД? Но инфа то уже не актуальная как бы, условно лента новостей какая нибудь. Посмотрели в БД, есть данные, ну ок, отобразили. И у нас получается всегда будут одни и те же новости в ленте?)

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

Ну такие записи имеют ttl, очистка кэша может быть какая угодно. Инвалидацию кэша может тебе прислать сервер если что-то в твоей ленте было изменено с того момента как ты это запросил.

Простите за оффтоп, этот чат по реактивному программированию в Java или вообще по реактивному программированию ? Я спрашиваю, потому что у меня каталог чатов по категориям(если админы захотят кину ссылку), вот думаю куда этот чат кинуть.

Ну чтобы сервер что-то прислал ведь мы должны как раз запрос на сервер отправить, об этом я и говорю. Просто по тому алгоритму что описан получается что мы один раз только как будто с сервера загружаем инфу и все и потом всегда отображаем её и только её. Я про "посмотрели в БД — если нет загрузили с сервера — сохранили в БД"... Не найду нигде нормальных примеров с кэширование данных почему-то. Может есть какие-то ссылки? Чтобы с Rx.

Это общий алгоритм. Как БМВ. Навешивай логику. Базовый алгоритм таков

Ладно, буду дальше ресерчить, спасибо)

всем привет) подскажите пожалуйста оператор для того, чтобы вызвать функции между другими операторами? Например:

interactor.fetchDetails(data)
            .map(::mapData)
            .//Тут оператор чтобы вызвать некоторые функции, которые возвращают Unit
            .map(::mapData1)
           .observeOn(mainThread())
           .subscribe(::handleData)
           .addDisposable()

doOnNext

аа, точно) спасибо большое)

Completable.timer(1500, TimeUnit.MILLISECONDS).subscribe { startStreaming() }
The result of subscribe is not used

Что он хочет? я же Completable юзаю

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

чот туплю. как это на эрыкс переписать?..

а там есть что-то потоковое?

да, accountType и isDemoUser есть результаты разных эрыксовых цепочек

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

ну как. 2 цепочки, каждая дает boolean в итоге. и надо теперь вот такой иф сделать...

либо объединяй эти самые цепочки, либо, как я выше написал, результат в behavioursubject и ими уже манипулируй. хотя по сути итоговые сравнения все равно останутся