爲什麼定義懸浮劑我無法接受的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上調用清除。