在尝试将RxJava与room一起使用时，我得到一个错误，即生成的代码是错误的。当返回单曲时，它工作得很好。但是当使用flowable或observable时，它会向生成的方法添加额外的布尔参数，从而导致错误。查询 @Query("SELECT * FROM cards")
fun cardsStream(): Observable<List<Card>> 错误 error
浏览 24提问于2019-04-11得票数 4
回答已采纳
我使用的是Room persistence DB (可流动的)，我的意思是如果我存储在DB中，我可以听到更改。apiIcaSeResource .toFlowable()
// items -> Timber.e(it, "Error rea
浏览 3提问于2017-10-06得票数 1
回答已采纳
1回答
用RxJava与改造实现机房
、、、、
我正在尝试使用RxJava和Retrofit，在您推荐使用组件arch (在这个机会是不可能的，该项目是在和50%，只需要继续与拱门清洁)。 }
this.st
浏览 0提问于2018-07-26得票数 3
回答已采纳
1回答
我很难理解Flowable在房间中是如何工作的。我有这样的Dao方法void upsert(List<Site> sites);
Flowable<List<Site>> getSites();
我希望每当我调用upsert subscriber时，由
浏览 0提问于2017-12-26得票数 2
对于下面的代码，我得到了以下错误：@DaoFlowable<List<Friends>> getAllFriends();
Observable
浏览 0提问于2018-06-16得票数 0
回答已采纳
我使用的是干净的架构和MVVM模式，所以房间部分进入数据层，我将可观察对象从那里返回到域层，并通过将它们包装在LiveData中在表示层中使用它们。("delete from word_table")
@Query("delete from wo
浏览 7提问于2018-08-30得票数 1
回答已采纳
我正在使用rxjava & Room，在那里我试图更新db中的行列表。陷入事件不断触发的循环中@Query("SELECT * FROM movies")int updateMovie@WorkerThread return movieDao.getMovies(
浏览 42提问于2018-09-24得票数 0
回答已采纳
1回答
发出所有可合法的项并追加到列表中
、、、、
我们是否可以将Flowable设置为在准备就绪时发出每一项，但将其附加到list (类似于buffer(int size)，但没有明确的函数)--我对返回Flowable <List <ItemEntity更改搜索查询时，希望再次收到新列表。(query) Flowable.fromIterable(it)
.map {= -1 AND active IS
浏览 7提问于2022-10-07得票数 0
回答已采纳
2回答
房间数据库全动态查询
、、、、
我有对象硬币的房间数据库。@Query("select * from coin ORDER BY percent_change_24h asc limit :numberOfCoins")但是当我想为WHERE子句使用一个参数时，这
浏览 4提问于2018-01-10得票数 8
回答已采纳
1回答
我试图在房间DAO上使用Flowable，但它给出了这个错误： error: Not sure how to convert a Cursor to this method's return typeFlowable<List<Category>> getAllCategories(); 我的查询如下所示： @Query("select * from categories_table orderby name;")
Flowable&
浏览 13提问于2021-01-31得票数 2
我在使用RxJava concat运算符时遇到了一个问题。我有两个观察点，第一个从服务器数据库发出结果，另一个从本地数据库发出结果，然后我连接：Observable<MyResult> remoteObservable(tId);
.doOnNext(result -> /* Do my stu
浏览 10提问于2016-09-03得票数 2
回答已采纳
我有一个安卓应用程序，它使用房间和RxJava。 假设我有两个表box(id)和ball(id, color, boxId)。我需要一个查询，它返回所有的盒子和每种颜色的球的数量。Flowable<List<BoxWithBallsCount>> getBallsWithCount(); 拥有它： BoxWithBallsCount(Box box, BoxCount boxCount)publi
浏览 17提问于2020-01-15得票数 0
回答已采纳
4回答
我正在尝试进行一个查询，以搜索名称包含文本的所有对象：fun loadHamsters(: Flowable<List<Hamster>>Error:no viable alternative at input 'SELECT * FROM hamster WHERE nameLIKE %'
Error:There is a problem with the que
浏览 20提问于2017-05-25得票数 152
回答已采纳
我以前曾使用MediatorLiveData将来自FCM、Room和网络的结果合并到我的存储库中。效果很好。然而，现在我想从RxJava获得更多的复杂性和额外的奖金。这就是我这次决定使用RxJava的原因。我可以把房间和网络和Observable.concatArrayEager(my _observables结合起来。我在我的BroadCastReceiver中接收到FCM，然后通知我的存储库的livedata，它通知了我的MediatorLiveData.如何使用RxJava?
浏览 0提问于2018-08-25得票数 1
在Rxjava1中，我们可以订阅一个可观察对象，如下所示：Observable<T>.subscribe(asyncSubject不知道如何在Rxjava2 Flowable中实现同样的功能？我在想像这样的事情.doOnComplete { t -> asyncSubject.OnComplete() }
.subscribe { t -> asyncSubject.onNext
浏览 6提问于2019-07-23得票数 0
回答已采纳
1回答
代理在数据加载时将此资源保存到缓存中。我尝试使用Publisher::cache方法，但这对我来说不是一个好的选择，因为它将所有接收到的数据保存在内存中，这是不可接受的，因为缓存的数据可能只有很少的GB大小。
浏览 0提问于2020-06-16得票数 4
回答已采纳
我有两个来自房间DB的查询：Flowable<List<BasketItem>> getAll();
Flowable<Long> totalSum();
如何将此查询合并为一个查询？
浏览 0提问于2018-06-25得票数 1
java1.8支持，如下所示： targetCompatibility 1.8}at retrofit2.adapter.rxjava2.BodyObservable.subscribeActual(BodyObservable.java:34)
at io.reactivex.Observable.subscribe(Observable.java
浏览 3提问于2017-05-22得票数 13
回答已采纳
3回答
我有一个任务，我必须读取文件并将其存储到Observable。我曾尝试在内部使用BufferedReader并使用Observable.fromCallable()来创建一个可调用的函数，但效果不是很好。我使用的是RxJava 2.0。
浏览 2提问于2017-04-17得票数 5
2回答
我有以下提供Flowable<User>流的@Dao：interface UsersDao { fun loadUsers(): Flowable<List<User>>我希望流的订阅者在数据库发生某些更改时立即接收数据库的更新。订阅Room的Flowable后，我将获得开箱即用的功能。
我想要的是:如果数据库是空的，我想执行一个web请求，并将用户保存到数据库中。订阅者将自动接收刚
浏览 23提问于2018-01-28得票数 1
回答已采纳
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号