Flowable<List<Item>> от сервера. После этого мне необходимо каждый элемент добавить в локальный список cashes и затем добавить в БД. Но код во втором doOnNext не выполняется.return remoteDataSource.loadItem(true).doOnNext {
Log.d("Log", it.toString())
caches.clear()
localDataSource.clearData()
}.take(1).flatMap { list -> Flowable.fromIterable(list) }.doOnNext {
Log.d("Log", it.title)
caches.add(it)
localDataSource.addItem(it)
}.toList().toFlowable()
remoteDataSource.loadItem(true)
.flatMap {
cache.clear().andThen(Observable.just(it))
}
.flatMap { list ->
Observable.fromIterable(list)
.flatMapCompletable { cache.add(it) }
.andThen(Observable.just(list))
}
Средний
Простой
Средний
