Présentation de Ngrx OnRunEffects

Question

Plusieurs écouteurs d'effets doivent être exécutés jusqu'à ce que l'utilisateur se déconnecte. En tant que tel, j'essaie de mettre en œuvre OnRunEffects.

Un segment de mes user.actions.ts est:

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

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

export type UserActions = LoadUser; 

Je suis en train de mettre en œuvre OnRunEffects comme:

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

Cependant, takeUntil se plaint qu'il a besoin que Observable. J'ai donc essayé:

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

Cela à son tour, provoque l'effet de ne pas déclencher. De la lecture du code, on dirait qu'il déclare:

1. Quand vous voyez ces actions
2. exécuter les effets
3. jusqu'à ce que vous voyez cette autre action.

Qu'est-ce que je fais mal?

Answer 1

-moi si je me trompe Si oui, au lieu de penser à takeUntil, mais vous ne voulez pas run until the user has logged out, vous pourriez vouloir exécuter ces effets si l'utilisateur est toujours connecté:

@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 

.

Answer 2

Essayez ceci:

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

Documentation ont été mis à jour: https://github.com/ngrx/platform/commit/4b606d581d18866576b9632b0537953c2b6006c4