diff --git a/packages/dart_client/lib/src/api/channel.dart b/packages/dart_client/lib/src/api/channel.dart
index 3ba9aa1f..45dd5da8 100644
--- a/packages/dart_client/lib/src/api/channel.dart
+++ b/packages/dart_client/lib/src/api/channel.dart
@@ -489,7 +489,7 @@ class Channel {
   }) async {
     final cachedReplies = await _client.chatPersistenceClient?.getReplies(
       parentId,
-      lessThan: options?.lessThan,
+      options: options,
     );
     if (cachedReplies != null && cachedReplies.isNotEmpty) {
       state?.updateThreadInfo(parentId, cachedReplies);
diff --git a/packages/dart_client/lib/src/db/chat_persistence_client.dart b/packages/dart_client/lib/src/db/chat_persistence_client.dart
index c0cb68b2..19a9164e 100644
--- a/packages/dart_client/lib/src/db/chat_persistence_client.dart
+++ b/packages/dart_client/lib/src/db/chat_persistence_client.dart
@@ -20,7 +20,7 @@ abstract class ChatPersistenceClient {
   /// Get stored replies by messageId
   Future<List<Message>> getReplies(
     String parentId, {
-    String lessThan,
+    PaginationParams options,
   });
 
   /// Get stored connection event
diff --git a/packages/stream_chat_persistence/lib/src/dao/message_dao.dart b/packages/stream_chat_persistence/lib/src/dao/message_dao.dart
index 0b6ba97c..57aa055d 100644
--- a/packages/stream_chat_persistence/lib/src/dao/message_dao.dart
+++ b/packages/stream_chat_persistence/lib/src/dao/message_dao.dart
@@ -79,7 +79,7 @@ class MessageDao extends DatabaseAccessor<MoorChatDatabase>
   /// [messages.parentId] with [parentId]
   Future<List<Message>> getThreadMessagesByParentId(
     String parentId, {
-    String lessThan,
+    PaginationParams options,
   }) async {
     final msgList = await Future.wait(await (select(messages).join([
       innerJoin(users, messages.userId.equalsExp(users.id)),
@@ -89,8 +89,8 @@ class MessageDao extends DatabaseAccessor<MoorChatDatabase>
         .map(_messageFromJoinRow)
         .get());
 
-    if (lessThan != null) {
-      final lessThanIndex = msgList.indexWhere((m) => m.id == lessThan);
+    if (options?.lessThan != null) {
+      final lessThanIndex = msgList.indexWhere((m) => m.id == options.lessThan);
       msgList.removeRange(lessThanIndex, msgList.length);
     }
     return msgList;
diff --git a/packages/stream_chat_persistence/lib/src/stream_chat_persistence_client.dart b/packages/stream_chat_persistence/lib/src/stream_chat_persistence_client.dart
index c0aceff5..49a59423 100644
--- a/packages/stream_chat_persistence/lib/src/stream_chat_persistence_client.dart
+++ b/packages/stream_chat_persistence/lib/src/stream_chat_persistence_client.dart
@@ -142,11 +142,11 @@ class StreamChatPersistenceClient extends ChatPersistenceClient {
   @override
   Future<List<Message>> getReplies(
     String parentId, {
-    String lessThan,
+    PaginationParams options,
   }) {
     return _db.messageDao.getThreadMessagesByParentId(
       parentId,
-      lessThan: lessThan,
+      options: options,
     );
   }