1回答
我的TeamDao里有这个 Flowable<Team> getRivals(int teamIdsubscribe(team -> Log.d("HomeActivity", team.getName()));
每当Team表的任何行中有任何更改时，不管它是否具有id61，我都会看到我的this订阅者在调用
浏览 1提问于2018-02-02得票数 2
回答已采纳
我使用的是Room persistence DB (可流动的)，我的意思是如果我存储在DB中，我可以听到更改。apiIcaSeResource .toFlowable()
})
fun loadIte
浏览 3提问于2017-10-06得票数 1
回答已采纳
我有一个Android应用程序，使用Room保存我的收藏夹。在我的UseCase中，我有下面这段代码来进行调用 favoritesRepository.getAll()
.flatMap { Flowable.just(it) }我从我的favoritesRepository中检索了一个Flowable<List<Favorite>>，并希望在发出网络请求后将每个收藏夹都变成一个项目，我的方法返回一个Flowable<List<Item>>
浏览 23提问于2019-09-18得票数 0
回答已采纳
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<List<Category>>
浏览 13提问于2021-01-31得票数 2
database.leadsDao().getLeads(leadState.name) val len = it.size.toLong() .flatMap { database.orderDao()没有它，流就不会调用订阅者的onNext。流一直在等待更多的项，这是不应该发生的，因为F
浏览 2提问于2017-08-27得票数 3
回答已采纳
1回答
用RxJava与改造实现机房
、、、、
我需要这样做，因为我的视图通过查询从房间调用数据，但是如果我的数据库中没有数据调用我的web服务，那么我的web服务的响应将转换为实体，并保存在我的db ( room )中，并在将数据列表返回给我的视图之后OnConflictStrategy.REPLACE) Flowable
浏览 0提问于2018-07-26得票数 3
回答已采纳
我的视图模型调用存储库方法，从房间数据库和网络中获取一些数据。private val observerScheduler: Scheduler //this method fetches data from roomoverride fun getData(): Flowable<Boolean> {
return localDatasource.shouldFetchRemote另外，当我从远程源获取数据时，我检查线程，它是主线程，
浏览 11提问于2019-09-08得票数 0
回答已采纳
我正在使用的一件事是Flowable (或Observable)用于我的Room数据库，它在我的getAll()方法中获取数据库中的所有注释并更新适配器。在Room中，如果该方法返回一个Flowable，则每次数据更改(插入、更新、删除)时都会调用订阅回调。
在Kotlin Coroutines中，这种方法的等价性是什么？
浏览 0提问于2019-07-24得票数 0
但是类可以访问数据，但是插入、删除或更新类不会触发对MainActivity订阅服务器中的MainActivity的调用。DeliciousDatabase.getInstance(context).taskDao()); }
public Flowablepublic TaskViewModel(TaskDataSource dataSource) { }
public <e
浏览 0提问于2018-03-06得票数 5
回答已采纳
1回答
我和RxJava2和Retrofit2一起使用了Room。首先，我将存储库模式实现为本地模式，因此我查询本地数据，同时从远程获取本地数据，如果需要更新本地数据。在代码中，这将是： return db.dEventDataStore().getAll()
.
浏览 2提问于2017-09-05得票数 1
回答已采纳
2回答
我有Android Room的SQL查询，返回flowable：Flowable<Exercices> getExercicesById(int id);
在我的存储库中，我需要获取发出的元素，然后更改他的布尔值，然后调用新方法，该方法必须返回completable似乎flowable发出了很多元素，并且在订
浏览 0提问于2017-07-27得票数 1
io.soulpicks.android.model.db.PlacesDao_Impl$6.call (PlacesDao_Impl.java:693)android.arch.persistence.room.RxRoom$4.apply (RxRoom.java:108)
io.reactivex.internal.operators.flowable.FlowableMapjava.util.concurr
浏览 1提问于2019-01-21得票数 2
1回答
我在切换按钮上有一个旋转动画，如下所示，如果我独立运行，它工作得很好。rotateAnimation.duration = AppConstants.ROTATE_ANIMATION_TIMErotateAnimation.repeatMode = Animation.REVERSE
itemView.t
浏览 3提问于2017-10-30得票数 0
2回答
我有以下提供Flowable<User>流的@Dao：interface UsersDao { fun loadUsers(): Flowable<List<User>>我希望流的订阅者在数据库发生某些更改时立即接收数据库的更新。订阅Room的Flowable后，我将获得开箱即用的功能。
我想要的是:如果数据库是空的，我想执行一个web请求，并将用户保存到数据库中。订阅者将自动接收刚
浏览 23提问于2018-01-28得票数 1
回答已采纳
我有一个带有一个实体和DAO的Room数据库，它允许插入对象并作为Flowable观察SELECT查询。当我订阅这个Flowable，然后向数据库中插入一个新对象时，不会发出新的结果。{ fun insert(user: User)
fun observeUsers(): FlowableAndroidJUnit4::class)
@Te
浏览 10提问于2018-11-17得票数 0
2回答
房内可流动
、、、
@Dao @Query("SELECT * FROM User WHERE id = :id") Completable insert(User user);属地annotationProcessor "andro
浏览 3提问于2020-01-11得票数 3
回答已采纳
我正在使用rxjava & Room，在那里我试图更新db中的行列表。陷入事件不断触发的循环中@Query("SELECT * FROM movies")int updateMovie@WorkerThread return movieDao.getMovies().flatMap
浏览 42提问于2018-09-24得票数 0
回答已采纳
2回答
房间数据库观察者
、、、
在Room数据库中，我想添加一些观察者，通知如下: delete，insert，update。
我确实通过创建一个接口来实现它，并且适配器实现了它。
浏览 1提问于2019-01-29得票数 0
4回答
房间支持RxJava 3
、、、
我在项目中使用带有文件室的RxJava3，但收到以下错误下面是我收到错误的DAO接口方法Flowable<List<WishListMovie>> getWishList();implementation "androidx.room</e
浏览 5提问于2020-06-14得票数 6
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
