Flutter Redux: как дождаться нескольких результатов отправки и отправить действия после завершения всех действий - PullRequest
Новая
       7

Flutter Redux: как дождаться нескольких результатов отправки и отправить действия после завершения всех действий

0 голосов
/ 07 февраля 2020

Когда приложение запускается, я отправляю действие FetchLocalDataRequestAction, перехватываю это действие в промежуточном программном обеспечении и отправляю несколько действий. Я хочу отправить FetchLocalDataCompleteAction действия, когда все действия завершены. Я ожидал, что функция отправки выдаст Future, который я могу ждать, и когда все Future будут завершены, я мог бы отправить полное действие. Я использую промежуточное программное обеспечение redux_epics для выполнения побочных эффектов с использованием потоков

Middleware 

fetchLocalData<State>(
  Store<State> store,
  action,
  NextDispatcher next
){
  if(action is FetchLocalDataRequestAction){
    final futureLanguage = store.dispatch(FetchPreferredLanguageRequestAction());
    print('futureLanguage : $futureLanguage '); // null
    store.dispatch(FetchLocalUserRequestAction());
    store.dispatch(FetchOnboardingStatusRequestAction());
  }

  next(action);
}

Epics 

Stream fetchUserEpic(Stream actions, EpicStore<AppState> store) =>
    actions.whereType<FetchLocalUserRequestAction>()
    .debounceTime(Duration(seconds: 5))
    .switchMap((action) => _fetchUser());

  Stream _fetchUser() => 
    handleException<AuthResponse, FetchLocalUserResultAction, FetchLocalUserErrorAction>(
      api: () => _mergeUser(),
      onResult: (result) => FetchLocalUserResultAction(result),
      onError: (error) => FetchLocalUserErrorAction(error)
    );

  Future<AuthResponse> _mergeUser() async {
      final token = await SharedPreferenceService.getAccessToken();
      final user = await SharedPreferenceService.getUser();

      return AuthResponse(token: token, user: user);
  }

  Stream fetchPreferredLanguageEpic(Stream actions, EpicStore<AppState> store) =>
    actions.whereType<FetchPreferredLanguageRequestAction>()
    .switchMap((action) => _fetchPreferredLanguage());

  Stream _fetchPreferredLanguage() =>
    handleException<String, FetchPreferredLanguageResultAction, FetchPreferredLanguageErrorAction>(
      api: () => SharedPreferenceService.getLanguageCode(),
      onResult: (code) => FetchPreferredLanguageResultAction(code),
      onError: (error) => FetchPreferredLanguageErrorAction(error)
    );

   Stream fetchOnboardingStatusEpic(Stream actions, EpicStore<AppState> store) =>
    actions.whereType<FetchOnboardingStatusRequestAction>()
    .switchMap((action) => _fetchOnboardingStatus());

  Stream _fetchOnboardingStatus() =>
    handleException<OnboardingStatus, FetchOnboardingStatusResultAction, FetchOnboardingStatusErrorAction>(
      api: () => SharedPreferenceService.getOnboardingStatus(),
      onResult: (status) => FetchOnboardingStatusResultAction(status),
      onError: (error) => FetchOnboardingStatusErrorAction(error)
    );
...