Merge pull request #9 from hoc081098/selector

Selector

Author: hoc081098

.github/workflows/dart.yml

@@ -12,7 +12,7 @@ jobs:
     runs-on: ubuntu-latest
 
     container:
-      image:  google/dart:2.12-dev
+      image:  google/dart:2.12-beta
 
     steps:
     - uses: actions/checkout@v2

.travis.yml

@@ -1,6 +1,7 @@
 language: dart
 dart:
   - dev
+  - beta
 script:
   - dartanalyzer --fatal-infos --fatal-warnings ./lib ./test
   - dartfmt -n ./lib --set-exit-if-changed

example/counter.dart

@@ -38,11 +38,11 @@ void main() async {
 
   store.stateStream.listen(print);
 
-  await Stream.periodic(const Duration(seconds: 1), (i) => i + 1)
+  Stream.periodic(const Duration(milliseconds: 500), (i) => i + 1)
       .take(10)
       .map((i) => i.isEven ? Increment(i) : Decrement(i))
-      .forEach(store.dispatch);
+      .dispatchTo(store);
 
-  await Future(() {});
+  await Future<void>.delayed(const Duration(seconds: 6));
   await store.dispose();
 }

lib/rx_redux.dart

@@ -4,5 +4,6 @@ export 'src/logger.dart';
 export 'src/reducer.dart';
 export 'src/reducer_exception.dart';
 export 'src/redux_store_stream_transformer.dart';
+export 'src/selectors.dart';
 export 'src/side_effect.dart';
 export 'src/store.dart';

lib/src/reducer.dart

@@ -7,5 +7,4 @@
 /// * Param [currentState] [S] The type of the state
 /// * Param [newAction] [A] The type of the Actions
 ///
-
 typedef Reducer<A, S> = S Function(S currentState, A newAction);

lib/src/redux_store_stream_transformer.dart

@@ -87,7 +87,7 @@ class ReduxStoreStreamTransformer<A, S> extends StreamTransformerBase<A, S> {
   @override
   Stream<S> bind(Stream<A> stream) {
     late StreamController<S> controller;
-    List<StreamSubscription<dynamic>>? subscriptions;
+    List<StreamSubscription<Object?>>? subscriptions;
     StreamController<WrapperAction>? _actionController;
 
     void onListen() {
@@ -204,7 +204,7 @@ class ReduxStoreStreamTransformer<A, S> extends StreamTransformerBase<A, S> {
     return controller.stream;
   }
 
-  Iterable<StreamSubscription<dynamic>> _listenSideEffects(
+  Iterable<StreamSubscription<Object?>> _listenSideEffects(
     StreamController<WrapperAction> actionController,
     GetState<S> getState,
     StreamController<S> stateController,