为什么定义悬浮剂我无法接受的DB

Question

@Query("SELECT * FROM userdata") 
Flowable<List<UserData>> allUserDatas(); 

@Insert(onConflict = OnConflictStrategy.REPLACE) 
List<Long> insert(List<UserData> datas); 


userDao.allUserDatas() 
take(1). 
filter(....) 
    .subscribeOn(io()) 
    .observeOn(mainThread()) 
    .subscribe(userDatas -> Log.i("TAG",""+userDatas)); 

我添加了在onAttach（同一片段订阅获取更新），但DB更新后，它不调用从数据库，获取认购为什么

Answer 1

我发现了这个问题。

这是因为take(1)，因为它是完整的，这就是为什么我不能听变化。删除take(1)固定的。

Answer 2

看起来您必须将您的Flowable allUserDatas（）添加到CompositeDisposable的实例，然后您的订阅将保持活动状态，直到您在CompositeDisposable上调用清除。