Created
June 11, 2020 14:57
-
-
Save mopcweb/7eb6df4f0c6f667b3f43e625f94b4b82 to your computer and use it in GitHub Desktop.
Simple Store for state management using rxjs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import { BehaviorSubject, Observable, Subscription } from 'rxjs'; | |
| import { cloneDeep } from 'lodash'; | |
| export interface State {} | |
| export class Store { | |
| private _state = new BehaviorSubject<State>({}); | |
| public constructor() { | |
| // this.state$.subscribe((state) => console.log('state >>>', state)); | |
| } | |
| /** Getter for current state */ | |
| public get state(): State { | |
| return cloneDeep(this._state.getValue()); | |
| } | |
| /** Getter for current state observable */ | |
| public get state$(): Observable<State> { | |
| return this._state.asObservable(); | |
| } | |
| /** | |
| * Subscribe for state updates | |
| * | |
| * @param [next] - Handler for each value emitted by the observable. | |
| * @param [error] - Handler for each error emitted by the observable. | |
| * @param [complete] - Handler for observable completeness. | |
| */ | |
| public sub(next?: (value: State) => void, error?: (error: Error) => void, complete?: () => void): Subscription { | |
| return this.state$.subscribe(next, error, complete); | |
| } | |
| /** | |
| * Unsubscribe state observable | |
| * | |
| * @param subscription- State subscription | |
| */ | |
| public unsub(subscription: Subscription): void { | |
| if (subscription) subscription.unsubscribe(); | |
| } | |
| /** | |
| * Setter (reducer) for state | |
| * | |
| * @param prop - Property to update | |
| * @param value - Value to update with | |
| */ | |
| public set<K extends keyof State>(prop: K, value: State[K]): void { | |
| if (!Object.hasOwnProperty.call(new State(), prop)) { | |
| throw new Error('There is no such property in App State'); | |
| } | |
| if (Object.hasOwnProperty.call(new State(), prop)) { | |
| this._state.next({ ...this.state, [prop]: cloneDeep(value) }); | |
| } | |
| } | |
| /** | |
| * Getter for current state or state property | |
| * | |
| * @param prop - Optional state property to get | |
| */ | |
| public get(): State; | |
| public get<K extends keyof State>(prop: K): State[K]; | |
| public get<K extends keyof State>(prop?: K): State | State[K] { | |
| if (!prop) return this._state.getValue(); | |
| return cloneDeep(this._state.getValue()[prop]); | |
| } | |
| } |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment