chore: updated

Author: hoc081098

analysis_options.yaml

@@ -1,10 +1,8 @@
 include: package:pedantic/analysis_options.1.9.0.yaml
 analyzer:
   exclude:
-    # Ignore generated files
-    - '**/*.g.dart'
-    - 'lib/src/generated/*.dart'
-    - 'lib/generated/*.dart'
+    - "lib/src/generated/*.dart"
+    - "lib/generated/*.dart"
 linter:
   rules:
     - prefer_final_locals

lib/main.dart

@@ -28,6 +28,7 @@ void main() async {
   const RemoteDataSource remoteDataSource = ApiService();
 
   // construct LocalDataSource
+  RxSharedPreferencesConfigs.logger = null;
   final rxPrefs = RxSharedPreferences.getInstance();
   final LocalDataSource localDataSource = SharedPrefUtil(rxPrefs);
 

lib/pages/home/home_bloc.dart

@@ -23,7 +23,7 @@ class HomeBloc extends DisposeCallbackBaseBloc {
   final Function0<void> logout;
 
   /// Output stream
-  final ValueStream<AuthenticationState> authState$;
+  final DistinctValueStream<AuthenticationState> authState$;
   final Stream<HomeMessage> message$;
 
   HomeBloc._({
@@ -60,7 +60,7 @@ class HomeBloc extends DisposeCallbackBaseBloc {
         .switchMap(uploadImage)
         .map(_resultToChangeAvatarMessage);
 
-    final authState$ = authenticationState$.publishValueDistinct();
+    final authState$ = authenticationState$.publishValueDistinct(null);
 
     final message$ = Rx.merge([logoutMessage$, updateAvatarMessage$]).publish();
 

lib/pages/reset_password/reset_password_page.dart

@@ -1,4 +1,5 @@
-import 'package:distinct_value_connectable_stream/distinct_value_connectable_stream.dart';
+import 'dart:async';
+
 import 'package:flutter/material.dart';
 import 'package:flutter_bloc_pattern/flutter_bloc_pattern.dart';
 import 'package:flutter_disposebag/flutter_disposebag.dart';
@@ -20,11 +21,7 @@ class ResetPasswordPage extends StatefulWidget {
 
 class _ResetPasswordPageState extends State<ResetPasswordPage>
     with SingleTickerProviderStateMixin<ResetPasswordPage>, DisposeBagMixin {
-  /// Observable of bool values,
-  /// Emits true if current page is request email page
-  /// and reset password page otherwise
-  final requestEmailS = PublishSubject<void>();
-  DistinctValueConnectableStream<bool> requestEmail$;
+  final requestEmailS = StreamController<void>(sync: true);
 
   AnimationController animationController;
   Animation<Offset> animationPosition;
@@ -77,26 +74,22 @@ class _ResetPasswordPageState extends State<ResetPasswordPage>
       ),
     );
 
-    requestEmail$ = requestEmailS
+    /// Stream of bool values.
+    /// Emits true if current page is request email page.
+    /// Otherwise, it is reset password page.
+    requestEmailS.stream
         .scan((acc, e, _) => !acc, true)
-        .publishValueSeededDistinct(seedValue: true);
-
-    bag.addAll([
-      requestEmail$.listen((requestEmailPage) {
-        if (requestEmailPage) {
-          animationController.reverse();
-        } else {
-          animationController.forward();
-        }
-      }),
-      requestEmail$.connect(),
-    ]);
+        .listen((requestEmailPage) => requestEmailPage
+            ? animationController.reverse()
+            : animationController.forward())
+        .disposedBy(bag);
+    requestEmailS.disposedBy(bag);
   }
 
   @override
   void dispose() {
-    animationController.dispose();
     super.dispose();
+    animationController.dispose();
   }
 
   void onToggle() => requestEmailS.add(null);

lib/utils/result.dart

@@ -30,8 +30,10 @@ abstract class Failure<T>
 }
 
 extension FlatMapResultExtension<T> on Stream<Result<T>> {
-  Stream<Result<R>> flatMapResult<R>(Stream<Result<R>> Function(T result) mapper) {
+  Stream<Result<R>> flatMapResult<R>(
+      Stream<Result<R>> Function(T result) mapper) {
     ArgumentError.checkNotNull(mapper, 'mapper');
+
     return flatMap((result) {
       if (result is Failure<T>) {
         final failure = Failure<R>((b) => b