流動性を規定する理由私はONATTACH（で同じフラグメントに加入してフェッチ添加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)); 

の更新を受信することができる）が、DBを更新した後、それはなぜ

Answer 1

問題が見つかりました。

take(1)が原因で、完全に完了したため変更を聞くことができませんでした。 take(1)を削除しました。

Answer 2

、DBからのフェッチのサブスクリプションを呼び出しませんあなたは、あなたのFlowable allUserDatas（）をCompositeDisposableのインスタンスに追加しなければならないと思われ、CompositeDisposableでclearを呼び出すまで、サブスクリプションは生き残ります。