Cacher is the code snippet organizer for pro developers

import { Injectable } from '@angular/core';
import { Actions, Effect, ofType } from '@ngrx/effects';
import { Observable, of } from 'rxjs';
import { UsersService } from '../_services/users.service';
import { Action } from '@ngrx/store';
import * as fromUsers from '.'
import { catchError, map, mergeMap } from 'rxjs/operators';
import { IUser } from '../_interfaces/user';

@Injectable()
export class UserEffects {

    constructor(private actions$: Actions,
        private userService: UsersService) {
    }

    @Effect()
    getUsers$: Observable<Action> = this.actions$.pipe(
        ofType(fromUsers.UserActionTypes.GetUserLoad),
        mergeMap(() =>
            this.userService.getUsers().pipe(
                map((user: IUser[]) => {
                    return new fromUsers.GetUserSuccess(user);
                }),
                catchError((error) =>
                    of(new fromUsers.GetUserFail(error)))
            )
        ));

    @Effect()
    postUser$: Observable<Action> = this.actions$.pipe(
        ofType(fromUsers.UserActionTypes.PostUser),
        map((action: fromUsers.PostUser) => action.payload),
        mergeMap((user: IUser) =>
            this.userService.postUser(user).pipe(
                map((user: IUser) => {
                    return new fromUsers.PostUserSuccess(user);
                }),
                catchError((error) =>
                    of(new fromUsers.PostUserFail(error)))
            )
        ));
}