@override Stream<T?> stream([Map? args]) { return store .record(T.toString()) .onSnapshot(db!) .map((record) => record == null ? null : mapper(record.value)); }