dev demo: stopwatching

Author: chrisbobbe

lib/model/store.dart

@@ -309,23 +309,35 @@ class PerAccountStore extends ChangeNotifier {
       for (final view in _messageListViews) {
         view.maybeAddMessage(event.message);
       }
+      final stopwatch = Stopwatch()..start();
       unreads.handleMessageEvent(event);
+      final t = (stopwatch..stop()).elapsed;
+      assert(debugLog('handleMessageEvent time: ${t.inMilliseconds}ms'));
     } else if (event is UpdateMessageEvent) {
       assert(debugLog("server event: update_message ${event.messageId}"));
       for (final view in _messageListViews) {
         view.maybeUpdateMessage(event);
       }
+      final stopwatch = Stopwatch()..start();
       unreads.handleUpdateMessageEvent(event);
+      final t = (stopwatch..stop()).elapsed;
+      assert(debugLog('handleUpdateMessageEvent time: ${t.inMilliseconds}ms'));
     } else if (event is DeleteMessageEvent) {
       assert(debugLog("server event: delete_message ${event.messageIds}"));
       // TODO handle in message lists
+      final stopwatch = Stopwatch()..start();
       unreads.handleDeleteMessageEvent(event);
+      final t = (stopwatch..stop()).elapsed;
+      assert(debugLog('handleDeleteMessageEvent time: ${t.inMilliseconds}ms'));
     } else if (event is UpdateMessageFlagsEvent) {
       assert(debugLog("server event: update_message_flags/${event.op} ${event.flag.toJson()}"));
       for (final view in _messageListViews) {
         view.maybeUpdateMessageFlags(event);
       }
+      final stopwatch = Stopwatch()..start();
       unreads.handleUpdateMessageFlagsEvent(event);
+      final t = (stopwatch..stop()).elapsed;
+      assert(debugLog('handleUpdateMessageFlagsEvent time: ${t.inMilliseconds}ms'));
     } else if (event is ReactionEvent) {
       assert(debugLog("server event: reaction/${event.op}"));
       for (final view in _messageListViews) {

lib/model/unreads.dart

@@ -39,6 +39,8 @@ import 'narrow.dart';
 //   messages and refresh [mentions] (see [mentions] dartdoc).
 class Unreads extends ChangeNotifier {
   factory Unreads({required UnreadMessagesSnapshot initial, required selfUserId}) {
+    final stopwatch = Stopwatch()..start();
+
     final streams = <int, Map<String, QueueList<int>>>{};
     final dms = <DmNarrow, QueueList<int>>{};
     final mentions = Set.of(initial.mentions);
@@ -60,13 +62,18 @@ class Unreads extends ChangeNotifier {
       dms[narrow] = QueueList.from(unreadHuddleSnapshot.unreadMessageIds);
     }
 
-    return Unreads._(
+    final result = Unreads._(
       streams: streams,
       dms: dms,
       mentions: mentions,
       oldUnreadsMissing: initial.oldUnreadsMissing,
       selfUserId: selfUserId,
     );
+
+    final t = (stopwatch..stop()).elapsed;
+    assert(debugLog('Unreads constructor time: ${t.inMilliseconds}ms'));
+
+    return result;
   }
 
   Unreads._({