rxjs_snippets_for_blog_post

oz_gonen_store.ts

import {BehaviorSubject, Observable} from 'rxjs';
export class StoreService<T> {
  private readonly state$: BehaviorSubject<T>;
  protected get state(): T {
    return this.state$.getValue();
  }
  constructor(initialState: T) {
    this.state$ = new BehaviorSubject<T>(initialState);
  }
  protected getState(): Observable<T> {
    return this.state$;
  }
  protected setState(newState: Partial<T>): void {
    this.state$.next({
      ...this.state,
      ...newState,
    });
  }
}