Channel read for the logged in user as a stream.
Stream<Read?> get currentUserReadStream => readStream.map((read) => read.firstWhereOrNull(_isCurrentUserRead));