From 90610caabda55449cc82c977624b32a56a127991 Mon Sep 17 00:00:00 2001
From: Kiril Tijsma <kiril@live.nl>
Date: Tue, 11 Mar 2025 15:49:47 +0100
Subject: [PATCH] fix(local/pending-message-repository): remove chunking

---
 .../src/local/local_pending_message_repository.dart | 13 +------------
 1 file changed, 1 insertion(+), 12 deletions(-)

diff --git a/packages/chat_repository_interface/lib/src/local/local_pending_message_repository.dart b/packages/chat_repository_interface/lib/src/local/local_pending_message_repository.dart
index 9a8dd91..ab86534 100644
--- a/packages/chat_repository_interface/lib/src/local/local_pending_message_repository.dart
+++ b/packages/chat_repository_interface/lib/src/local/local_pending_message_repository.dart
@@ -1,5 +1,4 @@
 import "dart:async";
-import "dart:math" as math;
 
 import "package:chat_repository_interface/chat_repository_interface.dart";
 import "package:chat_repository_interface/src/local/local_memory_db.dart";
@@ -15,9 +14,6 @@ class LocalPendingMessageRepository
   final StreamController<List<MessageModel>> _messageController =
       BehaviorSubject<List<MessageModel>>();
 
-  final Map<String, int> _startIndexMap = {};
-  final Map<String, int> _endIndexMap = {};
-
   @override
   Stream<List<MessageModel>> getMessages({
     required String chatId,
@@ -34,14 +30,7 @@ class LocalPendingMessageRepository
       );
       allMessages.sort((a, b) => a.timestamp.compareTo(b.timestamp));
 
-      _startIndexMap[chatId] ??= math.max(0, allMessages.length - chunkSize);
-      _endIndexMap[chatId] ??= allMessages.length;
-
-      var displayedMessages = allMessages.sublist(
-        _startIndexMap[chatId]!,
-        _endIndexMap[chatId],
-      );
-      _messageController.add(displayedMessages);
+      _messageController.add(allMessages);
     }
 
     return _messageController.stream;