1
1
import 'package:bloc/bloc.dart' ;
2
2
import 'package:bloc_concurrency/bloc_concurrency.dart' ;
3
3
import 'package:equatable/equatable.dart' ;
4
+
4
5
import 'package:ht_headlines_repository/ht_headlines_repository.dart' ;
5
6
import 'package:ht_main/headlines-feed/models/headline_filter.dart' ;
6
7
@@ -33,14 +34,16 @@ class HeadlinesFeedBloc extends Bloc<HeadlinesFeedEvent, HeadlinesFeedState> {
33
34
34
35
final HtHeadlinesRepository _headlinesRepository;
35
36
37
+ static const _headlinesFetchLimit = 20 ;
38
+
36
39
Future <void > _onHeadlinesFeedFilterChanged (
37
40
HeadlinesFeedFilterChanged event,
38
41
Emitter <HeadlinesFeedState > emit,
39
42
) async {
40
43
emit (HeadlinesFeedLoading ());
41
44
try {
42
45
final response = await _headlinesRepository.getHeadlines (
43
- limit: 20 ,
46
+ limit: _headlinesFetchLimit ,
44
47
category: event.category, // Pass category directly
45
48
source: event.source, // Pass source directly
46
49
eventCountry: event.eventCountry, // Pass eventCountry directly
@@ -86,7 +89,7 @@ class HeadlinesFeedBloc extends Bloc<HeadlinesFeedEvent, HeadlinesFeedState> {
86
89
emit (HeadlinesFeedLoading ());
87
90
try {
88
91
final response = await _headlinesRepository.getHeadlines (
89
- limit: 20 ,
92
+ limit: _headlinesFetchLimit ,
90
93
startAfterId: currentState.cursor,
91
94
category: currentState.filter.category, // Use existing filter
92
95
source: currentState.filter.source, // Use existing filter
@@ -109,7 +112,7 @@ class HeadlinesFeedBloc extends Bloc<HeadlinesFeedEvent, HeadlinesFeedState> {
109
112
emit (HeadlinesFeedLoading ());
110
113
try {
111
114
final response = await _headlinesRepository.getHeadlines (
112
- limit: 20 ,
115
+ limit: _headlinesFetchLimit ,
113
116
category: state is HeadlinesFeedLoaded
114
117
? (state as HeadlinesFeedLoaded ).filter.category
115
118
: null ,
0 commit comments