क्यों flowable को परिभाषित मैं डीबी

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 (में वही समान खंड में सदस्यता के साथ प्राप्त करने में कठिनाई जोड़ा के अद्यतन प्राप्त कर सकता है), लेकिन डीबी अद्यतन करने के बाद यह डीबी, से प्राप्त करने में कठिनाई की सदस्यता फोन नहीं करता है क्यों

Answer 1

मुझे समस्या मिली।

यह take(1) की वजह से था, क्योंकि यह पूर्ण हो गया है और इसलिए मैं परिवर्तनों को नहीं सुन सका। take(1) को हटाकर इसे ठीक किया गया।

Answer 2

ऐसा लगता है कि आपको कंपोजिट डिस्पोजेबल के उदाहरण में अपने फ़्लोएबल ऑलयूसरडेटा() को जोड़ना होगा और फिर जब तक आप कंपोजिट डिस्पोजेबल पर स्पष्ट नहीं कहेंगे तब तक आपकी सदस्यता ज़िंदा रहेगी।