CharlieGreenman

declare namespace moment {
  //..
  interface Moment extends Object {
    format(format?: string): string;

    startOf(unitOfTime: unitOfTime.StartOf): Moment;
    endOf(unitOfTime: unitOfTime.StartOf): Moment;
    //..
  }
  //..

CharlieGreenman

export declare class Actions<V = Action> extends Observable<V> {
  constructor(source?: Observable<V>);
  lift<R>(operator: Operator<V, R>): Observable<R>;
  //..
}  

CharlieGreenman

/**
* @whatItDoes Provides convenience methods for implementing common operations of persisting data. 
*/
export declare class DataPersistence <T> {
  store: Store<T>;
  actions: Actions;
constructor(store: Store<T>, actions: Actions);
// ...

CharlieGreenman

@Effect() loadPosts$ = this.dataPersistence.fetch(
  PostsActionTypes.LoadPosts,
  {
    run: (action: LoadPosts, state: PostsPartialState) => {
      return this.postsService.getPosts().pipe(
        map((posts: Post[]) => new PostsLoaded(posts))
      );
    },
    onError: (action: LoadPosts, error) => {
      console.error('Error', error);

CharlieGreenman

import { Subject } from 'rxjs';

const random = Math.random();
const randomVal$ = new Subject().next(random);

// Subscribe to run the combined functions
randomVals$.subscribe(x => console.log(x));
// 0.8771441274333971 (random number)
randomVals$.subscribe(x => console.log(x));
// 0.8771441274333971 (random number)

CharlieGreenman

import { Subject } from 'rxjs';

const randomVals$ = new Subject().next(Math.random());}

// Subscribe to run the combined functions
randomVals$.subscribe(x => console.log(x));
// 0.24957144215097515 (random number)
randomVals$.subscribe(x => console.log(x));
// 0.004617340049055896 (random number)

CharlieGreenman

import { Subject } from 'rxjs';

const randomVals$ = new Subject().next(Math.random());}

// Subscribe to run the combined functions
randomVals$.subscribe(x => console.log(x));
// 0.24957144215097515 (random number)
randomVals$.subscribe(x => console.log(x));
// 0.004617340049055896 (random number)

CharlieGreenman

@Effect()
loadAllBlogPosts$: Observable<any> = this.actions$.pipe(
  ofType(PokemonActions.loadPokemon),
  mergeMap(() =>
    this.postsService.getAll().pipe(
      map(posts => PokemonActions.loadPokemonSuccess({ posts })),
      catchError(message => of(PokemonActions.loadPostsFailed({ message })))
    )
  )
);  

CharlieGreenman

@Effect()
findAddresses: Observable<any> = this.actions.pipe(
  ofType(LocationActionTypes.FindAddresses),
  map(action => action.partialAddress),
  debounceTime(400),
  distinctUntilChanged(),
  switchMap(partialAddress => this.backend
    .findAddresses(partialAddress)
    .pipe(
      map(results => new FindAddressesFulfilled(results)),

CharlieGreenman

 @Effect()
  loadAllBlogPosts$: Observable<any> = this.actions$.pipe(
    ofType(PokemonActions.loadPokemon),
    mergeMap(() =>
      this.postsService.getAll().pipe(
        map(posts => PokemonActions.loadPokemonSuccess({ posts })),
        catchError(message => of(PokemonActions.loadPostsFailed({ message })))
      )
    )
  );