typed stream

support passing async functions to setState()
make sure stream gets updated after every setState()
0.2.0

Author: devxpy

example/pubspec.lock

@@ -1,69 +1,62 @@
 # Generated by pub
 # See https://dart.dev/tools/pub/glossary#lockfile
 packages:
-  archive:
-    dependency: transitive
-    description:
-      name: archive
-      url: "https://pub.dartlang.org"
-    source: hosted
-    version: "2.0.13"
-  args:
-    dependency: transitive
-    description:
-      name: args
-      url: "https://pub.dartlang.org"
-    source: hosted
-    version: "1.6.0"
   async:
     dependency: transitive
     description:
       name: async
       url: "https://pub.dartlang.org"
     source: hosted
-    version: "2.4.1"
+    version: "2.4.2"
   boolean_selector:
     dependency: transitive
     description:
       name: boolean_selector
       url: "https://pub.dartlang.org"
     source: hosted
     version: "2.0.0"
-  charcode:
+  characters:
     dependency: transitive
     description:
-      name: charcode
+      name: characters
       url: "https://pub.dartlang.org"
     source: hosted
-    version: "1.1.3"
-  collection:
+    version: "1.0.0"
+  charcode:
     dependency: transitive
     description:
-      name: collection
+      name: charcode
       url: "https://pub.dartlang.org"
     source: hosted
-    version: "1.14.12"
-  convert:
+    version: "1.1.3"
+  clock:
     dependency: transitive
     description:
-      name: convert
+      name: clock
       url: "https://pub.dartlang.org"
     source: hosted
-    version: "2.1.1"
-  crypto:
+    version: "1.0.1"
+  collection:
     dependency: transitive
     description:
-      name: crypto
+      name: collection
       url: "https://pub.dartlang.org"
     source: hosted
-    version: "2.1.4"
+    version: "1.14.13"
   cupertino_icons:
     dependency: "direct main"
     description:
       name: cupertino_icons
       url: "https://pub.dartlang.org"
     source: hosted
     version: "0.1.2"
+  fake_async:
+    dependency: transitive
+    description:
+      name: fake_async
+      url: "https://pub.dartlang.org"
+    source: hosted
+    version: "1.1.0"
   flutter:
     dependency: "direct main"
     description: flutter
@@ -79,20 +72,13 @@ packages:
     description: flutter
     source: sdk
     version: "0.0.0"
-  image:
-    dependency: transitive
-    description:
-      name: image
-      url: "https://pub.dartlang.org"
-    source: hosted
-    version: "2.1.12"
   matcher:
     dependency: transitive
     description:
       name: matcher
       url: "https://pub.dartlang.org"
     source: hosted
-    version: "0.12.6"
+    version: "0.12.8"
   meta:
     dependency: transitive
     description:
@@ -106,21 +92,7 @@ packages:
       name: path
       url: "https://pub.dartlang.org"
     source: hosted
-    version: "1.6.4"
-  petitparser:
-    dependency: transitive
-    description:
-      name: petitparser
-      url: "https://pub.dartlang.org"
-    source: hosted
-    version: "2.4.0"
-  quiver:
-    dependency: transitive
-    description:
-      name: quiver
-      url: "https://pub.dartlang.org"
-    source: hosted
-    version: "2.1.3"
+    version: "1.7.0"
   shared_preferences:
     dependency: transitive
     description:
@@ -155,7 +127,7 @@ packages:
       path: ".."
       relative: true
     source: path
-    version: "0.1.0"
+    version: "0.1.5"
   sky_engine:
     dependency: transitive
     description: flutter
@@ -174,7 +146,7 @@ packages:
       name: stack_trace
       url: "https://pub.dartlang.org"
     source: hosted
-    version: "1.9.3"
+    version: "1.9.5"
   stream_channel:
     dependency: transitive
     description:
@@ -202,28 +174,21 @@ packages:
       name: test_api
       url: "https://pub.dartlang.org"
     source: hosted
-    version: "0.2.15"
+    version: "0.2.17"
   typed_data:
     dependency: transitive
     description:
       name: typed_data
       url: "https://pub.dartlang.org"
     source: hosted
-    version: "1.1.6"
+    version: "1.2.0"
   vector_math:
     dependency: transitive
     description:
       name: vector_math
       url: "https://pub.dartlang.org"
     source: hosted
     version: "2.0.8"
-  xml:
-    dependency: transitive
-    description:
-      name: xml
-      url: "https://pub.dartlang.org"
-    source: hosted
-    version: "3.6.1"
 sdks:
-  dart: ">=2.6.0 <3.0.0"
+  dart: ">=2.9.0-14.0.dev <3.0.0"
   flutter: ">=1.12.13+hotfix.4 <2.0.0"

lib/shared_value.dart

@@ -34,15 +34,14 @@ class SharedValue<T> {
 
   SharedValue({this.key, T value}) {
     _value = value;
-    _updateNonce();
+    _update(rebuild: false);
   }
 
   /// The value held by this state.
   T get value => _value;
 
   /// Update [value] and rebuild the dependent widgets if it changed.
   set value(T newValue) {
-    _controller?.add(newValue);
     if (newValue == _value) return;
     setState(() {
       _value = newValue;
@@ -66,8 +65,13 @@ class SharedValue<T> {
 
     var ret = fn?.call();
 
-    _updateNonce();
-    stateManager.rebuild();
+    if (ret is Future) {
+      ret.then((_) {
+        _update();
+      });
+    } else {
+      _update();
+    }
 
     return ret;
   }
@@ -83,7 +87,7 @@ class SharedValue<T> {
   }
 
   /// A stream of [value]s that gets updated everytime the internal value is changed.
-  Stream get stream {
+  Stream<T> get stream {
     _controller ??= StreamController.broadcast();
     return _controller.stream;
   }
@@ -94,9 +98,18 @@ class SharedValue<T> {
     value = fn(_value);
   }
 
-  void _updateNonce() {
+  void _update({rebuild: true}) {
+    // update the nonce
     nonce = random.nextDouble();
     stateNonceMap[this] = nonce;
+
+    if (rebuild) {
+      // rebuild state manger widget
+      stateManager.rebuild();
+    }
+
+    // add value to stream
+    _controller?.add(value);
   }
 
   /// Try to load the value stored at [key] in shared preferences.