watch method

Stream<List<T>> watch()

Stream of matching entities; emits whenever data changes.

Implementation

Stream<List<T>> watch() {
  return _source.collection
      .watchWithFinder(_buildFinder())
      .map((maps) => _source.mapFromMaps(maps));
}