_notificationSub = FirestoreNotificationService.unreadCountStream()
      .listen((count) {
    if (!mounted) return;

    setState(() => unread = count);

    if (count > 0) {
      _ctl.stop();
      _ctl.forward(from: 0);
    } else {
      _ctl.reset();
    }
  });
}