为什么定义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()的同一个片段中添加了订阅提取但是在DB更新之后它没有调用从DB获取的订阅,为什么

Answer 1

我发现了这个问题.

这是因为take(1)它完整​​,这就是我无法听取变化的原因.删除take(1)固定的.