重新思考用于颤振飞镖的更改提要

Question

我在我的应用程序中使用 rethinkdb。我可以使用“rethink_db_ns”包插入和检索数据。但我需要实时获取数据。为此，我正在使用这种方法

Future<void> getData(RethinkDb r, Connection connection) async {
   var data = await r.table('users').run(connection);
   List list = data.toList();
   print(list);
   getData(r,connection);
}

此方法连续获取数据。我不想像这样连续获得相同的数据。我只在数据更改到数据库时才需要它。有没有更好的方法来获取 changefeed。

Answer 1

我是用这种方法做到的：

Future<dynamic> changeFeed(RethinkDb r, Connection connection)async{
print('running async.....');
var result = await r
    .table('tab_users')
    .changes()
    .run(connection).then((value) {
      print(value);
      Feed val = value;
      val.forEach((element) {
        print(element);
      });
});