streamUserChanges method

Implementation

Stream<UserModel?> streamUserChanges(String userId) {
  final userRef = _db.collection('Users').doc(userId);

  return userRef.snapshots().asyncMap((event) async {
    if (event.data() == null) {
      return null;
    }

    try {
      final user = await UserModel.fromDocumentSnapshot(event);

      return user;
    } catch (err) {
      _log.logCustom(UserDataServiceLog(
          'streamUserChanges failed', err, StackTrace.current));
      return null;
    }
  });
}