add possibility to reset and feed store, reset clears hydration so th…

…e store can be rehydrated if needed while feed is just replacing the state without other flags being updated apart from the property listeners (#13)

lib/event-store.ts

@@ -70,6 +70,23 @@ export function createEventStore<T extends object>(
     );
   };
 
+  const getResetObservable$ = (): Observable<T> => {
+    return globalEventStore$.pipe(
+      filter((event) => event.type === '@@RESET'),
+      map((event) => event.payload as T),
+      scan((__, curr) => curr),
+      distinctUntilChanged(),
+    );
+  };
+  const getFeedObservable$ = (): Observable<T> => {
+    return globalEventStore$.pipe(
+      filter((event) => event.type === '@@FEED'),
+      map((event) => event.payload as T),
+      scan((__, curr) => curr),
+      distinctUntilChanged(),
+    );
+  };
+
   const state$ = new BehaviorSubject<T>(initialState);
 
   globalEventStore$
@@ -80,7 +97,12 @@ export function createEventStore<T extends object>(
         }
       }),
       scan((state, event) => {
-        if (event.type === '@@INIT' || event.type === '@@HYDRATED') {
+        if (
+          event.type === '@@INIT' ||
+          event.type === '@@HYDRATED' ||
+          event.type === '@@RESET' ||
+          event.type === '@@FEED'
+        ) {
           return event.payload as T;
         }
 
@@ -134,6 +156,29 @@ export function createEventStore<T extends object>(
       };
     }, []);
 
+    useEffect(() => {
+      const subscription = getResetObservable$().subscribe({
+        next: (nextState) => {
+          setValue(get(type, nextState) as GetValueType<T, K>);
+        },
+      });
+
+      return () => {
+        subscription.unsubscribe();
+      };
+    }, []);
+    useEffect(() => {
+      const subscription = getFeedObservable$().subscribe({
+        next: (nextState) => {
+          setValue(get(type, nextState) as GetValueType<T, K>);
+        },
+      });
+
+      return () => {
+        subscription.unsubscribe();
+      };
+    }, []);
+
     useEffect(() => {
       const subscription = getPropertyObservable(
         type,
@@ -169,6 +214,17 @@ export function createEventStore<T extends object>(
         subscription.unsubscribe();
       };
     }, []);
+    useEffect(() => {
+      const subscription = getResetObservable$().subscribe({
+        next: () => {
+          setIsHydrated(false);
+        },
+      });
+
+      return () => {
+        subscription.unsubscribe();
+      };
+    }, []);
 
     return useMemo(() => isHydrated, [isHydrated]);
   };

lib/types.ts

@@ -27,4 +27,6 @@ export interface NestedEvent<T> {
 }
 export type SystemEvent<T> =
   | { type: '@@INIT'; payload: T }
-  | { type: '@@HYDRATED'; payload: T };
+  | { type: '@@HYDRATED'; payload: T }
+  | { type: '@@RESET'; payload: T }
+  | { type: '@@FEED'; payload: T };