mfp22

ngOnInit() {
  this.users$ = this.userService.users$;
}

mfp22

public muteFirst = <T,R>(first$: Observable<T>, second$: Observable<R>) => Observable.combineLatest(
  first$,
  second$,
  (a,b) => b
).distinctUntilChanged();

mfp22

requireUsers$ = this.userSelectors.needUsers$.pipe(
  filter(needUsers => needUsers),
  tap(() => this.store.dispatch({type: 'GET_USERS'})),
  switchMap(() => this.getUsers()),
  tap(users => this.store.dispatch({type: 'RECEIVE_USERS', users})),
  finalize(() => this.store.dispatch({type: 'CANCEL_GET_USERS'})),
  share(),
);

users$ = using(

mfp22

@Effect() actionX$ = this.updates$.pipe(
    ofType('ACTION_X'),
    map(toPayload),
    switchMap(payload => this.api.callApiX(payload).pipe(
        map(data => ({type: 'ACTION_X_SUCCESS', payload: data})),
        catch(err => Observable.of({type: 'ACTION_X_FAIL', payload: err})),
    )),
);
@Effect() actionY$ = this.updates$.pipe(
    ofType('ACTION_Y'),

mfp22

@Effect getUsers$ = this.actions$.pipe(
  ofType('GET_USERS', 'CANCEL_GET_USERS'),
  withLatestFrom(this.userSelectors.needUsers$),
  filter(([action, needUsers]) => needUsers),
  map(([action, needUsers]) => action),
  switchMap(action => action.type === 'CANCEL_GET_USERS' ? 
    Observable.of() :
    this.getUsers().pipe(
      map(users => ({type: 'RECEIVE_USERS', users})),
    ),

mfp22

ngOnDestroy() {
  this.store.dispatch({type: "CANCEL_GET_USERS"})
}

mfp22

@Effect getUsers$ = this.actions$.pipe(
  ofType('GET_USERS'),
  withLatestFrom(this.userSelectors.needUsers$),
  filter(([action, needUsers]) => needUsers),
  switchMap(() => this.getUsers()),
  map(users => ({type: 'RECEIVE_USERS', users})),
);

mfp22

ngOnInit() {
  this.store.dispatch({type: "GET_USERS"});
}

mfp22

@Effect() this.actions$.pipe(
  ofType("DELETE_ITEM_SUCCESS"),
  map(() => ({type: "REMOVE_FAVORITE_ITEM_ID"})),
);

mfp22

export interface State {
  items: {[index: number]: Item};
  favoriteItems: number[];
}