prepare 2.2.0 (#11)

* bum deps

* fix CI

* update

* update selector.dart

* update README.md

* imports

Author: hoc081098

.github/workflows/dart.yml

@@ -12,33 +12,33 @@ jobs:
     runs-on: ubuntu-latest
 
     container:
-      image:  google/dart:2.12-beta
+      image: google/dart:2.12
 
     steps:
-    - uses: actions/checkout@v2
+      - uses: actions/checkout@v2
 
-    - name: Install dependencies
-      run: pub get
+      - name: Install dependencies
+        run: pub get
 
-    - name: Analyze
-      run: dartanalyzer --fatal-infos --fatal-warnings ./lib ./test
+      - name: Analyze
+        run: dart analyze --fatal-infos --fatal-warnings
 
-    - name: Format code
-      run: dartfmt -n ./lib ./test --set-exit-if-changed
+      - name: Format code
+        run: dartfmt -n ./lib ./test --set-exit-if-changed
 
-    - name: Active coverage
-      run: pub global activate coverage
+      - name: Active coverage
+        run: pub global activate coverage
 
-    - name: Run tests
-      run: pub run test/rx_redux_test.dart
+      - name: Run tests
+        run: pub run test test/rx_redux_test.dart
 
-    - name: Start VM
-      run: dart --disable-service-auth-codes --enable-vm-service=8111 --pause-isolates-on-exit test/rx_redux_test.dart &
+      - name: Start Observatory
+        run: dart --disable-service-auth-codes --enable-vm-service=8111 --pause-isolates-on-exit test/rx_redux_test.dart &
 
-    - name: Collect coverage
-      run: nohup pub global run coverage:collect_coverage --port=8111 --out=coverage.json --wait-paused --resume-isolates
+      - name: Collect coverage
+        run: nohup pub global run coverage:collect_coverage --port=8111 --out=coverage.json --wait-paused --resume-isolates
 
-    - name: Format coverage
-      run: pub global run coverage:format_coverage --lcov --in=coverage.json --out=lcov.info --packages=.packages --report-on=lib
+      - name: Format coverage
+        run: pub global run coverage:format_coverage --lcov --in=coverage.json --out=lcov.info --packages=.packages --report-on=lib
 
-    - uses: codecov/codecov-action@v1
+      - uses: codecov/codecov-action@v1

.travis.yml

@@ -1,9 +1,9 @@
 language: dart
 dart:
-  - dev
+  - stable
   - beta
 script:
-  - dartanalyzer --fatal-infos --fatal-warnings ./lib ./test
+  - dart analyze --fatal-infos --fatal-warnings
   - dartfmt -n ./lib --set-exit-if-changed
   - pub get
   - pub global activate coverage

README.md

@@ -80,7 +80,17 @@ Whenever a `SideEffect` needs to know the current State it can use `GetState` to
 
 ### Selector
 
-TODO
+Inspirited by [NgRx memoized selector](https://ngrx.io/guide/store/selectors)
+-   Selectors can compute derived data, allowing Redux to store the minimal possible state.
+    
+-   Selectors are efficient. A selector is not recomputed unless one of its arguments changes.
+
+-   When using the `select`, `select2` to `select9`, `selectMany` functions, 
+    keeps track of the latest arguments in which your selector function was invoked. 
+    Because selectors are pure functions, the last result can be returned 
+    when the arguments match without re-invoking your selector function. 
+    This can provide performance benefits, particularly with selectors that perform expensive computation. 
+    This practice is known as memoization.
 
 ## Usage
 
@@ -305,6 +315,12 @@ Also `SideEffects` can be invoked by `Actions` from other `SideEffects`.
 
 **For a complete example check [the sample application incl. README](example/README.md)**
 
+## Examples
+
+| [Pagination list (load more) (endless scrolling)](https://github.com/hoc081098/load_more_flutter_BLoC_pattern_RxDart_and_RxRedux/tree/master/lib/pages/rx_redux) | [Flutter github search using rx_redux](https://github.com/hoc081098/flutter_github_search_rx_redux) |  
+| ------------- | ------------- |
+| <img src="https://github.com/hoc081098/hoc081098.github.io/blob/master/load_more/rx_redux_screen.gif?raw=true" height="480">                                     | <img src="https://github.com/hoc081098/hoc081098.github.io/blob/master/flutter_github_search_rx_redux/demo.gif?raw=true" height="480"> |
+
 ## FAQ
 
 ### I get a `StackOverflowError`

analysis_options.yaml

@@ -1,4 +1,4 @@
-include: package:pedantic/analysis_options.1.9.0.yaml
+include: package:pedantic/analysis_options.1.11.0.yaml
 
 analyzer:
   strong-mode:
@@ -8,3 +8,4 @@ linter:
   rules:
     - prefer_final_locals
     - public_member_api_docs
+    - prefer_relative_imports

example/selector.dart

@@ -1,5 +1,7 @@
 import 'package:built_collection/built_collection.dart';
+import 'package:disposebag/disposebag.dart';
 import 'package:distinct_value_connectable_stream/distinct_value_connectable_stream.dart';
+import 'package:pedantic/pedantic.dart';
 import 'package:rx_redux/rx_redux.dart';
 
 //
@@ -138,6 +140,7 @@ State reducer(State state, Action action) {
 }
 
 void main() async {
+  final bag = DisposeBag();
   final store = RxReduxStore<Action, State>(
       initialState: State(null, <Book>[].build(), null),
       sideEffects: [],
@@ -148,18 +151,23 @@ void main() async {
     (s) => s.selectedUser?.id,
     (s) => s.allBooks,
     (String? userId, BuiltList<Book> books) {
-      print(
-          '<> Call projector with userId=${userId} and books=${books.length}');
+      print('<> Call projector with userId=$userId and books=${books.length}');
 
       return userId != null && books.isNotEmpty
           ? books.where((b) => b.userId == userId).toBuiltList()
           : books;
     },
-  );
+  ).asBroadcastDistinctValueStream();
 
   // logging state.
   print('~> ${visibleBooks$.value}');
-  visibleBooks$.listen((s) => print('~> $s'));
+  unawaited(
+    visibleBooks$.listen((s) => print('1 ~> $s')).disposedBy(bag),
+  );
+  Future<void>.delayed(
+    const Duration(milliseconds: 500),
+    () => visibleBooks$.listen((s) => print('2 ~> $s')).disposedBy(bag),
+  );
 
   // dispatch actions.
   [
@@ -190,6 +198,7 @@ void main() async {
   print('---------------------------------------------------');
 
   // end by disposing store.
+  await bag.dispose();
   await store.dispose();
 }
 

lib/src/selectors.dart

@@ -2,15 +2,15 @@ import 'dart:async';
 
 import 'package:distinct_value_connectable_stream/distinct_value_connectable_stream.dart';
 
-import '../rx_redux.dart';
+import 'store.dart';
 
 /// Inspirited by [NgRx memoized selector](https://ngrx.io/guide/store/selectors)
 /// - Selectors can compute derived data, allowing Redux to store the minimal possible state.
 /// - Selectors are efficient. A selector is not recomputed unless one of its arguments changes.
 /// - When using the [select], [select2] to [select9], [selectMany] functions,
 ///   keeps track of the latest arguments in which your selector function was invoked.
 ///   Because selectors are pure functions, the last result can be returned
-///   when the arguments match without reinvoking your selector function.
+///   when the arguments match without re-invoking your selector function.
 ///   This can provide performance benefits, particularly with selectors that perform expensive computation.
 ///   This practice is known as memoization.
 typedef Selector<State, V> = V Function(State state);
@@ -23,7 +23,7 @@ typedef Selector<State, V> = V Function(State state);
 /// - When using the [select], [select2] to [select9], [selectMany] functions,
 ///   keeps track of the latest arguments in which your selector function was invoked.
 ///   Because selectors are pure functions, the last result can be returned
-///   when the arguments match without reinvoking your selector function.
+///   when the arguments match without re-invoking your selector function.
 ///   This can provide performance benefits, particularly with selectors that perform expensive computation.
 ///   This practice is known as memoization.
 extension SelectorsExtension<Action, State> on RxReduxStore<Action, State> {

lib/src/store.dart

@@ -7,6 +7,7 @@ import 'logger.dart';
 import 'reducer.dart';
 import 'redux_store_stream_transformer.dart';
 import 'side_effect.dart';
+import 'utils.dart';
 
 /// Determine equality.
 typedef Equals<T> = bool Function(T previous, T next);
@@ -47,7 +48,7 @@ class RxReduxStore<A, S> {
   final DistinctValueStream<S> _stateStream;
   final Stream<A> _actionStream;
 
-  final DisposeBag _bag;
+  final DisposeBag Function() _bag;
 
   const RxReduxStore._(
     this._dispatch,
@@ -91,14 +92,21 @@ class RxReduxStore<A, S> {
         .handleErrorIfNeeded(errorHandler)
         .publishValueDistinct(initialState, equals: equals);
 
-    final bag = DisposeBag(<Object>[stateStream.connect(), actionController]);
+    late final RxReduxStore<A, S> store;
+    late final bag = DisposeBag(
+        const <Object>[], '( RxReduxStore<$A, $S> ~ ${shortHash(store)} )');
 
-    return RxReduxStore._(
+    store = RxReduxStore._(
       actionController.add,
       stateStream,
       actionOutputController.stream,
-      bag,
+      () => bag,
     );
+
+    stateStream.connect().disposedBy(bag);
+    actionController.disposedBy(bag);
+
+    return store;
   }
 
   /// Get stream of states.
@@ -172,7 +180,7 @@ class RxReduxStore<A, S> {
   ///     Stream<LoadNextPageAction> loadNextPageActionStream;
   ///     store.dispatchMany(loadNextPageActionStream);
   void dispatchMany(Stream<A> actionStream) =>
-      _bag.add(actionStream.listen(_dispatch));
+      _bag().add(actionStream.listen(_dispatch));
 
   /// Dispose all resources.
   /// This method is typically called in `dispose` method of Flutter `State` object.
@@ -186,7 +194,7 @@ class RxReduxStore<A, S> {
   ///         super.dispose();
   ///       }
   ///     }
-  Future<void> dispose() => _bag.dispose();
+  Future<void> dispose() => _bag().dispose();
 }
 
 /// Get current state synchronously.

lib/src/utils.dart

@@ -8,3 +8,8 @@ extension MapIndexedIterableExtensison<T> on Iterable<T> {
     }
   }
 }
+
+/// Returns a 5 character long hexadecimal string generated from
+/// [Object.hashCode]'s 20 least-significant bits.
+String shortHash(Object? object) =>
+    object.hashCode.toUnsigned(20).toRadixString(16).padLeft(5, '0');

lib/src/wrapper_action.dart

@@ -11,13 +11,8 @@ abstract class ActionType {
 
   static final _sideEffects = <int, _SideEffect>{};
 
-  factory ActionType._sideEffect(int index) {
-    final sideEffect = _sideEffects[index];
-    if (sideEffect != null) {
-      return sideEffect;
-    }
-    return _sideEffects[index] = _SideEffect(index);
-  }
+  factory ActionType._sideEffect(int index) =>
+      _sideEffects.putIfAbsent(index, () => _SideEffect(index));
 
   @override
   String toString() {

pubspec.yaml

@@ -1,22 +1,22 @@
 name: rx_redux
 description: Redux implementation based on Dart Stream, with the power of RxDart. Reactive redux store for Dart & Flutter.
-version: 2.2.0-nullsafety.2
+version: 2.2.0
 author: Petrus Nguyen Thai Hoc <[email protected]>
 homepage: https://github.com/hoc081098/rx_redux.git
 repository: https://github.com/hoc081098/rx_redux.git
 issue_tracker: https://github.com/hoc081098/rx_redux/issues
 
 environment:
-  sdk: '>=2.12.0-0 <3.0.0'
+  sdk: '>=2.12.0 <3.0.0'
 
 dependencies:
   meta: ^1.3.0
-  distinct_value_connectable_stream: ^1.2.0-nullsafety.5
-  disposebag: ^1.5.0-nullsafety.0
+  distinct_value_connectable_stream: ^1.2.0
+  disposebag: ^1.5.0
 
 dev_dependencies:
-  pedantic: ^1.10.0-nullsafety.3
-  test: ^1.16.0-nullsafety.12
-  rxdart: ^0.26.0-nullsafety.0
-  built_collection: ^5.0.0-nullsafety.0
-  tuple: ^2.0.0-nullsafety.0
+  pedantic: ^1.11.0
+  test: ^1.17.3
+  rxdart: ^0.26.0
+  built_collection: ^5.0.0
+  tuple: ^2.0.0