feat: added a MultiListenerStreamController as an alternative to a Be…

…haviorSubject

CHANGELOG.md

@@ -1,3 +1,9 @@
+# 0.5.0
+
+## Feat
+
+- Added a MultiListenerStreamController that is a simplified version of the BehaviorSubject from RxDart
+
 # 0.4.0
 
 ## Feat

lib/impaktfull_architecture.dart

@@ -23,6 +23,7 @@ export 'src/util/number_formatter/number_formatter_util.dart';
 export 'src/util/storage/key_value/key_value_store.dart';
 export 'src/util/storage/secure/secure_store.dart';
 export 'src/util/storage/shared_prefs/shared_prefs_store.dart';
+export 'src/util/stream/multi_listener_stream_controller.dart';
 export 'src/widget/lifecycle/lifecycle_widget.dart';
 export 'src/widget/mixin/after_layout.dart';
 export 'src/widget/provider/provider_widget.dart';

lib/src/util/stream/multi_listener_stream_controller.dart

@@ -0,0 +1,50 @@
+import 'dart:async';
+
+/// A simplified BehaviorSubject implementation
+class MultiListenerStreamController<T> {
+  late T _value;
+  bool _hasValue = false;
+
+  final _controller = StreamController<T>.broadcast();
+
+  MultiListenerStreamController([T? initialValue]) {
+    if (initialValue != null) {
+      _value = initialValue;
+      _hasValue = true;
+    }
+  }
+
+  /// Get the current value
+  T get value {
+    if (!_hasValue) {
+      throw StateError('No value has been emitted yet.');
+    }
+    return _value;
+  }
+
+  /// Emit a new value
+  void add(T newValue) {
+    _value = newValue;
+    _hasValue = true;
+    _controller.add(newValue);
+  }
+
+  /// Listen to the stream
+  Stream<T> get stream {
+    return _controller.stream.transform(
+      StreamTransformer.fromHandlers(
+        handleData: (data, sink) {
+          if (_hasValue) {
+            sink.add(_value); // Emit the current value to new listeners
+          }
+        },
+      ),
+    );
+  }
+
+  /// Close the stream
+  Future<void> close() => _controller.close();
+
+  /// Check if the stream is closed
+  bool get isClosed => _controller.isClosed;
+}