Refactor theme management to use ValueNotifier for reactive updates

Signed-off-by: Hans Kokx <hans.d.kokx@gmail.com>

lib/src/services/reactive_theme/reactive_theme_service.dart

@@ -1,6 +1,5 @@
-import "dart:async";
-
 import "package:arcane_framework/arcane_framework.dart";
+import "package:flutter/foundation.dart";
 import "package:flutter/material.dart";
 
 part "reactive_theme_extensions.dart";
@@ -34,12 +33,8 @@ class ArcaneReactiveTheme extends ArcaneService {
   /// Tracks the current system theme mode
   ThemeMode _currentSystemThemeMode = ThemeMode.system;
 
-  final StreamController<ThemeMode> _systemStreamController =
-      StreamController<ThemeMode>.broadcast(
-    onCancel: () {
-      I._systemStreamController.close();
-    },
-  );
+  final ValueNotifier<ThemeMode> _systemThemeNotifier =
+      ValueNotifier<ThemeMode>(ThemeMode.system);
 
   // ************************************************************************ //
   // * MARK: ThemeMode
@@ -52,32 +47,24 @@ class ArcaneReactiveTheme extends ArcaneService {
   ThemeMode get currentThemeMode => _currentThemeMode;
   ThemeMode _currentThemeMode = ThemeMode.light;
 
-  /// Stream of `ThemeMode` changes that can be listened to for reactive UI updates.
-  Stream<ThemeMode> get themeModeChanges => I._themeModeStreamController.stream;
+  /// ValueListenable of `ThemeMode` changes that can be listened to for reactive UI updates.
+  ValueListenable<ThemeMode> get themeModeChanges => I._themeModeNotifier;
 
-  final StreamController<ThemeMode> _themeModeStreamController =
-      StreamController<ThemeMode>.broadcast(
-    onCancel: () {
-      I._themeModeStreamController.close();
-    },
-  );
+  final ValueNotifier<ThemeMode> _themeModeNotifier =
+      ValueNotifier<ThemeMode>(ThemeMode.light);
 
   // ************************************************************************ //
   // * MARK: ThemeData
   // ************************************************************************ //
   /// The currently active theme style.
   ThemeData get currentTheme => _currentTheme;
-  ThemeData _currentTheme = ThemeData();
+  ThemeData _currentTheme = ThemeData.light();
 
-  /// Stream of `ThemeData` changes that can be listened to for reactive UI updates.
-  Stream<ThemeData> get themeDataChanges => I._themeStreamController.stream;
+  /// ValueListenable of `ThemeData` changes that can be listened to for reactive UI updates.
+  ValueListenable<ThemeData> get themeDataChanges => I._themeNotifier;
 
-  final StreamController<ThemeData> _themeStreamController =
-      StreamController<ThemeData>.broadcast(
-    onCancel: () {
-      I._themeStreamController.close();
-    },
-  );
+  final ValueNotifier<ThemeData> _themeNotifier =
+      ValueNotifier<ThemeData>(ThemeData.light());
 
   // ************************************************************************ //
   // * MARK: Light/Dark theme
@@ -143,13 +130,9 @@ class ArcaneReactiveTheme extends ArcaneService {
 
     _currentSystemThemeMode =
         context.isDarkMode ? ThemeMode.dark : ThemeMode.light;
-    _systemStreamController.add(_currentSystemThemeMode);
+    _systemThemeNotifier.value = _currentSystemThemeMode;
     _updateTheme(_currentSystemThemeMode);
 
-    final ThemeData theme = systemThemeMode == ThemeMode.dark ? dark : light;
-    _themeStreamController.add(theme);
-    _currentTheme = theme;
-
     return I;
   }
 
@@ -164,8 +147,12 @@ class ArcaneReactiveTheme extends ArcaneService {
   /// ```
   ArcaneReactiveTheme setDarkTheme(ThemeData theme) {
     _darkTheme.value = theme;
-    _themeStreamController.add(theme);
-    _currentTheme = theme;
+
+    // Only update current theme if we're currently in dark mode
+    if (_currentThemeMode == ThemeMode.dark) {
+      _themeNotifier.value = theme;
+      _currentTheme = theme;
+    }
 
     return I;
   }
@@ -181,8 +168,12 @@ class ArcaneReactiveTheme extends ArcaneService {
   /// ```
   ArcaneReactiveTheme setLightTheme(ThemeData theme) {
     _lightTheme.value = theme;
-    _themeStreamController.add(theme);
-    _currentTheme = theme;
+
+    // Only update current theme if we're currently in light mode
+    if (_currentThemeMode == ThemeMode.light) {
+      _themeNotifier.value = theme;
+      _currentTheme = theme;
+    }
 
     return I;
   }
@@ -197,13 +188,32 @@ class ArcaneReactiveTheme extends ArcaneService {
     _lightTheme.value = ThemeData.light();
     _followingSystemTheme = false;
     _updateTheme(ThemeMode.light);
-    _themeStreamController.add(_lightTheme.value);
+    _themeNotifier.value = _lightTheme.value;
     _currentTheme = _lightTheme.value;
   }
 
   /// Updates the current theme mode and broadcasts the change.
   void _updateTheme(ThemeMode themeMode) {
     _currentThemeMode = themeMode;
-    _themeModeStreamController.add(themeMode);
+    _themeModeNotifier.value = themeMode;
+
+    // Update the current theme data based on the theme mode
+    final ThemeData newTheme = themeMode == ThemeMode.dark ? dark : light;
+    _currentTheme = newTheme;
+    _themeNotifier.value = newTheme;
+  }
+
+  /// Disposes of the theme service resources.
+  ///
+  /// This method should be called when the service is no longer needed
+  /// to clean up ValueNotifiers and prevent memory leaks.
+  @override
+  void dispose() {
+    _systemThemeNotifier.dispose();
+    _themeModeNotifier.dispose();
+    _themeNotifier.dispose();
+    _darkTheme.dispose();
+    _lightTheme.dispose();
+    super.dispose();
   }
 }

lib/src/services/reactive_theme/reactive_theme_switcher.dart

@@ -1,5 +1,3 @@
-import "dart:async";
-
 import "package:arcane_framework/arcane_framework.dart";
 import "package:flutter/material.dart";
 
@@ -17,27 +15,15 @@ class ArcaneThemeSwitcher extends StatefulWidget {
 
 class _ArcaneThemeSwitcherState extends State<ArcaneThemeSwitcher>
     with WidgetsBindingObserver {
-  late final StreamSubscription<ThemeMode> _themeModeSubscription;
-  late final StreamSubscription<ThemeData> _themeSubscription;
-
   @override
   void initState() {
     super.initState();
     // Register as an observer to detect system theme changes
     WidgetsBinding.instance.addObserver(this);
-
-    _themeModeSubscription = ArcaneReactiveTheme.I.themeModeChanges.listen((_) {
-      setState(() {});
-    });
-    _themeSubscription = ArcaneReactiveTheme.I.themeDataChanges.listen((_) {
-      setState(() {});
-    });
   }
 
   @override
   void dispose() {
-    _themeModeSubscription.cancel();
-    _themeSubscription.cancel();
     // Clean up the observer when the widget is disposed
     WidgetsBinding.instance.removeObserver(this);
     super.dispose();
@@ -45,11 +31,21 @@ class _ArcaneThemeSwitcherState extends State<ArcaneThemeSwitcher>
 
   @override
   Widget build(BuildContext context) {
-    return _ArcaneTheme(
-      themeMode: ArcaneReactiveTheme.I.currentThemeMode,
-      followSystem: ArcaneReactiveTheme.I.isFollowingSystemTheme,
-      theme: ArcaneReactiveTheme.I.currentTheme,
-      child: widget.child,
+    return ValueListenableBuilder<ThemeMode>(
+      valueListenable: ArcaneReactiveTheme.I.themeModeChanges,
+      builder: (BuildContext context, ThemeMode themeMode, Widget? child) {
+        return ValueListenableBuilder<ThemeData>(
+          valueListenable: ArcaneReactiveTheme.I.themeDataChanges,
+          builder: (BuildContext context, ThemeData themeData, Widget? child) {
+            return _ArcaneTheme(
+              themeMode: themeMode,
+              followSystem: ArcaneReactiveTheme.I.isFollowingSystemTheme,
+              theme: themeData,
+              child: widget.child,
+            );
+          },
+        );
+      },
     );
   }