rxjs.store.ts

import { BehaviorSubject, Observable } from 'rxjs';
import { Injectable } from '@angular/core';

@Injectable()
export abstract class Store<T> {
  private _state$: BehaviorSubject<T>;
  
  protected constructor(defaults: T) {
    this.state$ = new BehaviorSubject(defaults);
  }
  
  public get state$(): Observable<T> {
    return this._state$.asObservable();
  }
  
  public getState(): T {
    return this._state$.getValue();
  }
  
  public setState(nextState: T): void {
    this._state$.next(nextState);
  }
  
}