Оператор карты rxjs не запускается в трубе после switchMap

Когда дело дошло до rxjs, я считал себя довольно сообразительным, но не могу понять, что делаю не так. Я пытаюсь изучить ngrx, преобразовав мой логин пользователя в эффект. Мой эффект срабатывает правильно, и с моего сервера возвращается правильный ответ токена (подтвержденный путем входа в консоль), но оператор карты никогда не запускается в моем эффекте.

Вот мой код эффекта:

@Injectable()
export class UserEffects {

constructor(
    private authService: AuthService,
    private actions$: Actions
) { }

    @Effect() loginUser$ = this.actions$
    .ofType<userActions.LoginUserAction>(userActions.LOGIN_USER).pipe(
        switchMap(action => this.authService.Login(action.payload)),
        map(user => (new userActions.LoginUserSuccessAction(user)))
    );
}

и запрос в моем сервисном слое:

public Login(model: ILogin) {
return this.http.post<string>(`${baseUrl}api/login`, model).pipe(
  // Returns the object to be stored in AppState
  map(response => this.GetTokenInformation(response))
);

}

Я пробовал использовать flatMap и mergeMap на случай, если мне что-то не хватало в документации ngrx, но ни один из них тоже не работал.

мои операторы импортируются так:

import { map, switchMap } from 'rxjs/operators';

дайте мне знать, если я могу предоставить что-нибудь еще ... спасибо!


person Clouse24    schedule 29.05.2018    source источник


Ответы (1)


попробуйте использовать что-то вроде этого: Эффект входа из примера приложения

loginUser$ = this.actions$.pipe(
  ofType<userActions.LoginUserAction>(userActions.LOGIN_USER),
  map(action => action.payload),
  exhaustMap((auth: any) =>
    this.authService
      .Login(auth)
      .pipe(
        map(user => (new userActions.LoginUserSuccessAction(user)))
      )
  )
);

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

Узнайте больше о различиях этих двух операторов

person m.akbari    schedule 29.05.2018