Stream<QuerySnapshot> stream(CollectionReference ref) { return ref // .limit(limit) // TODO .snapshots(); }