added measureTime transformer for UsersBloc

analysis_options.yaml

@@ -2,6 +2,8 @@ include: package:flutter_lints/flutter.yaml
 
 linter:
   rules:
+    unintended_html_in_doc_comment: false
+
 
 formatter:
   trailing_commas: preserve

lib/core/bloc/transformers/measure_time.dart

@@ -0,0 +1,43 @@
+import 'dart:async';
+
+import 'package:flutter/foundation.dart';
+import 'package:flutter_bloc/flutter_bloc.dart';
+
+/// Example:
+///
+/// on<MyEvent>(
+///   _onEvent,
+///   transformer: measureTime<MyEvent>(
+///     blocName: 'MyBloc',
+///   ),
+/// );
+///
+EventTransformer<E> measureTime<E>({
+  String? blocName,
+}) {
+  return (events, mapper) {
+    return events.asyncExpand(
+      (event) {
+        final stopwatch = Stopwatch()..start();
+        final eventName = event.toString();
+        final blocPrefix = blocName != null ? '[$blocName]' : '';
+
+        debugPrint('$blocPrefix ⏱️ Event STARTED: $eventName');
+
+        final controller = StreamController<E>();
+
+        mapper(event).listen(
+          controller.add,
+          onError: controller.addError,
+          onDone: () {
+            stopwatch.stop();
+            debugPrint('$blocPrefix ⏱️ $eventName: ${stopwatch.elapsedMilliseconds} ms');
+            controller.close();
+          },
+        );
+
+        return controller.stream;
+      },
+    );
+  };
+}

lib/features/users/bloc/users_bloc.dart

@@ -1,4 +1,5 @@
 import 'package:bloc_concurrency/bloc_concurrency.dart';
+import 'package:bloc_example/core/bloc/transformers/measure_time.dart';
 import 'package:bloc_example/features/users/bloc/users_bloc_event.dart';
 import 'package:bloc_example/features/users/bloc/users_bloc_state.dart';
 import 'package:bloc_example/features/users/model/user.dart';
@@ -9,7 +10,12 @@ class UsersBloc extends HydratedBloc<UsersBlocEvent, UsersBlocState> {
   final UsersRepository usersRepository;
 
   UsersBloc({required this.usersRepository}) : super(UsersBlocStateLoading()) {
-    on<UsersBlocEventFetch>(_onFetch);
+    on<UsersBlocEventFetch>(
+      _onFetch,
+      transformer: measureTime(
+        blocName: 'UsersBloc',
+      ),
+    );
     on<UsersBlocEventFetchMore>(
       _onFetchMore,
       transformer: droppable(),