Merge pull request #6 from alvarobcprado/feature/add-auto-initial-state-stream-data

Feature/add auto initial state stream data

Author: alvarobcprado

CHANGELOG.md

@@ -1,3 +1,7 @@
+## 0.0.6
+* **break**: remove `initialData` and `emptyWidget` from `StateStream` collector
+* add automatically emit of initial value to `StateStream`
+
 ## 0.0.5
 * remove stream from ActionNotifier in favor of extension type `ActionStream`
 * remove stream from StateNotifier in favor of extension type `StateStream`

README.md

@@ -63,7 +63,6 @@ class _MainAppState extends State<MainApp> {
               // Collect the data from the stream
               // and build a widget based on its data
               counter.countStream.collectAsWidget(
-                initialData: 0,
                 (value) {
                   return Text('Count: $value');
                 },

example/lib/calculator.dart

@@ -4,7 +4,7 @@ import 'package:view_model_macro/view_model_macro.dart';
 class Calculator {
   Calculator() {
     countStream.collect((countValue) {
-      if (countValue % 3 == 0) {
+      if (countValue % 3 == 0 && countValue > 0) {
         _dispatchShowSnackBar();
       }
     });

example/lib/main.dart

@@ -43,7 +43,6 @@ class _MainAppState extends State<MainApp> {
                 mainAxisSize: MainAxisSize.min,
                 children: [
                   counter.countStream.collectAsWidget(
-                    initialData: 0,
                     (value) {
                       return Text('Count: $value');
                     },

example/pubspec.lock

@@ -144,6 +144,14 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "1.9.0"
+  rxdart:
+    dependency: transitive
+    description:
+      name: rxdart
+      sha256: "5c3004a4a8dbb94bd4bf5412a4def4acdaa12e12f269737a5751369e12d1a962"
+      url: "https://pub.dev"
+    source: hosted
+    version: "0.28.0"
   sky_engine:
     dependency: transitive
     description: flutter
@@ -211,7 +219,7 @@ packages:
       path: ".."
       relative: true
     source: path
-    version: "0.0.4"
+    version: "0.0.5"
   vm_service:
     dependency: transitive
     description:

lib/src/core/collector.dart

@@ -7,19 +7,14 @@ import 'package:view_model_macro/src/widgets/stream_listener.dart';
 /// Extension methods for collecting data from [StateStream]s.
 extension StateStreamCollectorX<T> on StateStream<T> {
   /// Collects the data from the stream to build a widget based on its data.
-  Widget collectAsWidget(
-    Widget Function(T) builder, {
-    Widget? emptyData,
-    T? initialData,
-  }) {
+  Widget collectAsWidget(Widget Function(T) builder) {
     return StreamBuilder(
       stream: stream,
-      initialData: initialData,
       builder: (context, snapshot) {
         if (snapshot.hasData) {
           return builder(snapshot.data as T);
         } else {
-          return emptyData ?? const SizedBox.shrink();
+          return const SizedBox.shrink();
         }
       },
     );

lib/src/notifiers/notifier.dart

@@ -16,9 +16,10 @@ import 'package:meta/meta.dart';
 /// {@endtemplate}
 abstract class Notifier<T> {
   /// {@macro Notifier}
-  Notifier();
+  Notifier([StreamController<T>? controller]):
+      _controller = controller ?? StreamController<T>.broadcast();
 
-  final StreamController<T> _controller = StreamController<T>.broadcast();
+  final StreamController<T> _controller;
   final List<StreamSubscription<T>> _subscriptions = [];
 
   /// Notifies all listeners with the new value.

lib/src/notifiers/state_notifier.dart

@@ -1,5 +1,6 @@
 import 'dart:async';
 
+import 'package:rxdart/rxdart.dart';
 import 'package:view_model_macro/src/notifiers/notifier.dart';
 
 /// The type wrapper for [Stream]s emitted by a [StateNotifier].
@@ -19,7 +20,7 @@ extension type StateStream<T>(Stream<T> stream) {}
 /// {@endtemplate}
 class StateNotifier<T> extends Notifier<T> {
   /// {@macro StateNotifier}
-  StateNotifier(this._state);
+  StateNotifier(this._state) : super(BehaviorSubject<T>.seeded(_state));
 
   T _state;
 

pubspec.yaml

@@ -1,6 +1,6 @@
 name: view_model_macro
 description: "Experimental support for ViewModel classes in Dart using pckg:macros."
-version: 0.0.5
+version: 0.0.6
 repository: https://github.com/alvarobcprado/view_model_macro
 topics: [macros, view-model]
 
@@ -13,6 +13,7 @@ dependencies:
     sdk: flutter
   macros: ^0.1.0-main.5
   meta: ^1.15.0
+  rxdart: ^0.28.0
 
 dev_dependencies:
   flutter_test: