diff --git a/lib/logic/bloc/backups/backups_bloc.dart b/lib/logic/bloc/backups/backups_bloc.dart index fcdedfeb..5f918868 100644 --- a/lib/logic/bloc/backups/backups_bloc.dart +++ b/lib/logic/bloc/backups/backups_bloc.dart @@ -17,6 +17,37 @@ part 'backups_state.dart'; class BackupsBloc extends Bloc { BackupsBloc() : super(BackupsInitial()) { + on( + _loadState, + ); + on( + _resetState, + ); + on( + _updateState, + ); + on( + _initializeRepository, + ); + on( + _forceSnapshotListUpdate, + ); + on( + _createBackups, + ); + on( + _restoreBackup, + ); + on( + _setAutobackupPeriod, + ); + on( + _setAutobackupQuotas, + ); + on( + _forgetSnapshot, + ); + final connectionRepository = getIt(); _apiStatusSubscription = connectionRepository.connectionStatusStream @@ -58,37 +89,6 @@ class BackupsBloc extends Bloc { add(const BackupsServerLoaded()); isLoaded = true; } - - on( - _loadState, - ); - on( - _resetState, - ); - on( - _updateState, - ); - on( - _initializeRepository, - ); - on( - _forceSnapshotListUpdate, - ); - on( - _createBackups, - ); - on( - _restoreBackup, - ); - on( - _setAutobackupPeriod, - ); - on( - _setAutobackupQuotas, - ); - on( - _forgetSnapshot, - ); } final BackblazeApi backblaze = BackblazeApi(); diff --git a/lib/logic/bloc/server_jobs/server_jobs_bloc.dart b/lib/logic/bloc/server_jobs/server_jobs_bloc.dart index 0104f3e5..c0396661 100644 --- a/lib/logic/bloc/server_jobs/server_jobs_bloc.dart +++ b/lib/logic/bloc/server_jobs/server_jobs_bloc.dart @@ -15,15 +15,6 @@ class ServerJobsBloc extends Bloc { : super( ServerJobsInitialState(), ) { - final apiConnectionRepository = getIt(); - _apiDataSubscription = apiConnectionRepository.dataStream.listen( - (final ApiData apiData) { - add( - ServerJobsListChanged([...apiData.serverJobs.data ?? []]), - ); - }, - ); - on( _mapServerJobsListChangedToState, ); @@ -33,6 +24,15 @@ class ServerJobsBloc extends Bloc { on( _mapRemoveAllFinishedJobsToState, ); + + final apiConnectionRepository = getIt(); + _apiDataSubscription = apiConnectionRepository.dataStream.listen( + (final ApiData apiData) { + add( + ServerJobsListChanged([...apiData.serverJobs.data ?? []]), + ); + }, + ); } StreamSubscription? _apiDataSubscription; diff --git a/lib/logic/bloc/services/services_bloc.dart b/lib/logic/bloc/services/services_bloc.dart index 1d5293fd..0f7e927d 100644 --- a/lib/logic/bloc/services/services_bloc.dart +++ b/lib/logic/bloc/services/services_bloc.dart @@ -12,6 +12,19 @@ part 'services_state.dart'; class ServicesBloc extends Bloc { ServicesBloc() : super(ServicesInitial()) { + on( + _updateList, + ); + on( + _reload, + ); + on( + _restart, + ); + on( + _move, + ); + final connectionRepository = getIt(); _apiDataSubscription = connectionRepository.dataStream.listen( @@ -29,19 +42,6 @@ class ServicesBloc extends Bloc { ), ); } - - on( - _updateList, - ); - on( - _reload, - ); - on( - _restart, - ); - on( - _move, - ); } Future _updateList(