angular-state-management-47.ts

import { Injectable } from '@angular/core';
import { Actions, Effect } from '@ngrx/effects';
import { Action } from '@ngrx/store';
import { Observable, of } from 'rxjs';

import * as project from './../actions/projects';
import { ProjectsService } from './../services/projects.service';

@Injectable()
export class ProjectEffects {
    @Effect()
    loadProjectsDetails$: Observable<Action> = this.actions$
        .ofType<project.LoadProjectsDetails>(project.LOAD_PROJECTS_DETAILS)
        .switchMap(action =>
            this.projectsService.loadProjectsDetails(action.payload)
                .map(projectDetails => new project.LoadProjectsDetailsSuccess(projectDetails))
                .catch((error) => of(new project.LoadProjectsDetailsError(error)))
        );

    constructor(private actions$: Actions,
        private projectsService: ProjectsService) { }
}