watch method

Stream<List<MapChangeNotification<UserId, DtoMyUser>>> watch()

Returns the Stream of real-time changes happening with the DtoMyUsers.

Implementation

Stream<List<MapChangeNotification<UserId, DtoMyUser>>> watch() {
  return stream((db) {
    return db
        .select(db.myUsers)
        .watch()
        .map((items) => {for (var e in items.map(_MyUserDb.fromDb)) e.id: e})
        .changes();
  });
}