如何获得完整的与房间流动的？

Question

我有一个Android应用程序使用房间来保存我的收藏夹。

@Query("SELECT * FROM favorites ORDER BY lastConsultation DESC")
fun getAll() : Flowable<List<Favorite>>

favoritesRepository.getAll()
        .flatMap { Flowable.just(it) }
        .concatMapEager { Flowable.fromIterable(it) }
        .concatMapEager {
            itemRepository.getItem(it.id)
                .toFlowable()
        }
        .toList()
        .toFlowable()

当调用getItem时，ItemRepository返回一个。我从我的favoritesrepository中检索了一个flow > ，并希望在发出网络请求后将每个收藏夹转到一个项目中，我的方法返回一个flow >

我认为添加.flatmap{Flowable.just(it)}将创建一个新的Flowable，它将在项目发出后发出onComplete（因为Room不会发出onComplete）。

这段代码不起作用，onComplete从来没有被调用，所以.tolist()也没有被调用。

是否有一种方法可以实现这些调用（使用并发性，从而实现ConcatMapEagery)，同时保持我的可流动实现（我可以使用一个单独的实现来解决这个问题，但我会丢失MainActivity上的“自动通知”）？

Answer 1

我假设realtyrepository返回一个single。试试这个。

favoritesRepository
       .getAll()
       .switchMapSingle { Flowable
           .fromIterable(it)
           .concatMapEager { realtyRepository.getRealty(it.id).toFlowable() }
           .toList()
       }

这将得到我所理解的您想要的，但当数据库更改时，您仍然会得到通知。此外，switchmapsingle将确保，如果同时发生任何DB更新，您正在进行的任何工作都将被取消。