watchAll method

Stream<List<T>> watchAll()

Stream of all entities; emits whenever the collection changes.

Implementation

Stream<List<T>> watchAll() =>
    _collection.watchWithFinder(Finder()).map(mapFromMaps);