@@ -105,7 +105,8 @@ class ChannelsBlocState extends State<ChannelsBloc>
|
||||
}) async {
|
||||
final client = _streamChatCoreState!.client;
|
||||
|
||||
final clear = paginationParams.offset == 0;
|
||||
final offset = paginationParams.offset;
|
||||
final clear = offset == null || offset == 0;
|
||||
if (clear && _paginationEnded) {
|
||||
_paginationEnded = false;
|
||||
}
|
||||
|
||||
@@ -75,7 +75,9 @@ class UsersBlocState extends State<UsersBloc>
|
||||
}
|
||||
|
||||
try {
|
||||
final clear = pagination == null || pagination.offset == 0;
|
||||
final clear = pagination == null ||
|
||||
pagination.offset == null ||
|
||||
pagination.offset == 0;
|
||||
|
||||
final oldUsers = List<User>.from(users ?? []);
|
||||
|
||||
|
||||
@@ -74,7 +74,10 @@ void main() {
|
||||
messageFilters: any(named: 'messageFilters'),
|
||||
paginationParams: any(named: 'paginationParams'),
|
||||
)).thenAnswer(
|
||||
(_) async => SearchMessagesResponse()..results = messageResponseList,
|
||||
(_) async => SearchMessagesResponse()
|
||||
..results = messageResponseList
|
||||
..next = null
|
||||
..previous = null,
|
||||
);
|
||||
|
||||
messageSearchBlocState.search(filter: testFilter);
|
||||
@@ -177,7 +180,10 @@ void main() {
|
||||
messageFilters: any(named: 'messageFilters'),
|
||||
paginationParams: any(named: 'paginationParams'),
|
||||
)).thenAnswer(
|
||||
(_) async => SearchMessagesResponse()..results = messageResponseList,
|
||||
(_) async => SearchMessagesResponse()
|
||||
..results = messageResponseList
|
||||
..next = null
|
||||
..previous = null,
|
||||
);
|
||||
|
||||
messageSearchBlocState.search(filter: testFilter);
|
||||
@@ -206,8 +212,10 @@ void main() {
|
||||
messageFilters: any(named: 'messageFilters'),
|
||||
paginationParams: pagination,
|
||||
)).thenAnswer(
|
||||
(_) async =>
|
||||
SearchMessagesResponse()..results = paginatedMessageResponseList,
|
||||
(_) async => SearchMessagesResponse()
|
||||
..results = paginatedMessageResponseList
|
||||
..next = null
|
||||
..previous = null,
|
||||
);
|
||||
|
||||
messageSearchBlocState.search(pagination: pagination, filter: testFilter);
|
||||
@@ -269,7 +277,10 @@ void main() {
|
||||
messageFilters: any(named: 'messageFilters'),
|
||||
paginationParams: any(named: 'paginationParams'),
|
||||
)).thenAnswer(
|
||||
(_) async => SearchMessagesResponse()..results = messageResponseList,
|
||||
(_) async => SearchMessagesResponse()
|
||||
..results = messageResponseList
|
||||
..next = null
|
||||
..previous = null,
|
||||
);
|
||||
|
||||
messageSearchBlocState.search(filter: testFilter);
|
||||
|
||||
Reference in New Issue
Block a user