Понимание Ngrx OnRunEffects

У меня есть несколько прослушивателей эффектов, которые нужно запускать до тех пор, пока пользователь не выйдет из системы. Таким образом, я пытаюсь реализовать OnRunEffects. .

Сегмент моего user.actions.ts:

export const LOAD_USER = '[Users] Load User';

export class LoadUser implements Action {
  readonly type = LOAD_USER;
}

export type UserActions = LoadUser;

Я пытаюсь реализовать OnRunEffects как:

ngrxOnRunEffects(resolvedEffects: Observable<EffectNotification>) {
    return this.actions
                .ofType(UsersActions.LOAD_USER)
                .exhaustMap(() => resolvedEffects.takeUntil(AuthActions.LOGOUT_SUCCESS)
}

Однако takeUntil жалуется, что ему нужно как Observable. Итак, я попытался:

ngrxOnRunEffects(resolvedEffects: Observable<EffectNotification>) {
        return this.actions
                    .ofType(UsersActions.LOAD_USER)
                    .exhaustMap(() => resolvedEffects.takeUntil(
                        Observable.of(new AuthActions.LogoutSuccess())
                     )
    }

Это, в свою очередь, приводит к тому, что эффект не срабатывает. Судя по коду, в нем указано:

  1. Когда вы видите эти действия
  2. запустить эффекты
  3. пока вы не увидите это другое действие.

Что я делаю не так?


ngrx ngrx-effects
person Brandon    schedule 14.09.2017    source источник
comment
почему бы вам просто не использовать filter? В вашем распоряжении ofType<>().filter(IS THE USER CONNECTED)   -  person maxime1992    schedule 15.09.2017
comment
Пример пожалуйста?   -  person Brandon    schedule 15.09.2017
comment
Я сделал правильный ответ, не уверен, что он подходит для вашего варианта использования, но может помочь   -  person maxime1992    schedule 16.09.2017

Ответы (2)


arrow_upward
2
arrow_downward

Поправьте меня, если я ошибаюсь, но вы можете не захотеть run until the user has logged out, вы можете просто захотеть запустить эти эффекты, если пользователь все еще вошел в систему. Если да, то вместо того, чтобы думать о takeUntil:

@Effect()
someEffect$: Observable<Action> = this.actions$
  .ofType<Your_Type>(Your_Action)
  .withLatestFrom(this.store$.select(state => state.users.isUserLoggedIn))
  .filter(([action, isUserLoggedIn]) => isUserLoggedIn)
  // here, you'll receive the actions only is the user is logged in
  // ... your code for the effect
person maxime1992    schedule 16.09.2017
comment
Очень интересно. Спасибо за ответ. Я должен быть в состоянии попробовать это сегодня. - person Brandon; 16.09.2017
comment
Пожалуйста. Поскольку вы заинтересованы в ngrx, я бы порекомендовал вам взглянуть на шаблон (на основе angular-cli), над которым я работал :) Много комментариев для объяснения + readme github.com/maxime1992/angular-ngrx-starter Дайте мне знать, как идут дела после того, как вы попробуете мое предложение :) - person maxime1992; 16.09.2017

arrow_upward
0
arrow_downward

Попробуй это:

ngrxOnRunEffects(resolvedEffects: Observable<EffectNotification>) {
    return this.actions
        .ofType(UsersActions.LOAD_USER)
        .exhaustMap(() => resolvedEffects.takeUntil(this.actions.ofType(AuthActions.LOGOUT_SUCCESS)))
}

Обновлена ​​документация: https://github.com/ngrx/platform/commit/4b606d581d188660376b9332b0 а>

person bbaia    schedule 27.09.2017
comment
Когда я добавляю этот код в свои классы эффектов, кажется, что он препятствует правильному срабатыванию .startWith(). - person Brandon; 28.09.2017
comment
Он не срабатывает после действия LOAD_USER? - person bbaia; 30.09.2017
comment
Правильный. Эффект никогда не запускается, если я реализую onRunEffects, где это было раньше. - person Brandon; 30.09.2017