0

我正在为我的聊天应用程序使用 sqlbrite。我需要观察一个数据库,但范围不固定。

Observable<Query> messages = db.createQuery("messages", "SELECT * FROM users WHERE timestamp > ? ");

我需要传入一个参数newestMessage.sentTime,但是 latestMessage 会在新消息到来时不断更新。所以我不能只将电流newestMessage作为参数传递。

4

1 回答 1

0

单个查询执行的结果永远不会改变并代表一个快照。要获得更多消息,您必须重新执行查询,即createQuery再次调用。

于 2017-09-15T06:48:31.660 回答