Stream<List<T>> watch(Query query) { return table.watch(query).map((e) => e.map((l) => fromDb(l)).toList()); }