Pourquoi définir Flowable je pouvais recevoir des mises à jour de la 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)); 

j'ai ajouté aller chercher avec abonnement dans le même fragment dans onAttach() mais après DB mise à jour ne remet pas l'abonnement d'aller chercher de DB, pourquoi

Answer 1

J'ai trouvé le problème.

C'était à cause de take(1), comme il fait compléter et c'est pourquoi je ne pouvais pas écouter les changements. Suppression take(1) a corrigé cela.

Answer 2

Il semble que vous deviez ajouter votre allUserDatas() à une instance de CompositeDisposable et que votre abonnement soit actif jusqu'à ce que vous appeliez clear sur CompositeDisposable.