fix: defer local storage querying

The method obtained the value before the stream was observed. Fixed this in order to get the latest value at the time of subscription.

projects/ngx-lss/src/lib/ngx-local-storage.service.spec.ts

@@ -44,6 +44,21 @@ describe('NgxLocalStorageService', () => {
       expect(resultValues).toContain(secondData);
     }));
 
+    it('should return latest value at the time of subscription', () => {
+      const testKey = 'some-key';
+      const latestDummyData = { someNewData: 12345 };
+
+      const resultValues: unknown[] = [];
+
+      spectator.service.save(testKey, { someData: 123 }).subscribe();
+      const data$ = spectator.service.get(testKey);
+      spectator.service.save(testKey, latestDummyData).subscribe();
+      data$.subscribe(data => resultValues.push(data));
+
+      expect(resultValues.length).toBe(1);
+      expect(resultValues).toContain(latestDummyData);
+    });
+
     it('returns initial null in case storage is empty', () => {
       const key = 'some-non-existent-key';
       const observerSpy = createObserverSpy();

projects/ngx-lss/src/lib/ngx-local-storage.service.ts

@@ -38,9 +38,14 @@ export class NgxLocalStorageService {
    * @param key Unique key.
    */
   public get<T = unknown>(key: string): Observable<T | null> {
-    return this.watchStorageChangeByKey(key).pipe(
+    const initialValue$ = defer(() => of(this.obtainFromStorageByKey<T>(key)));
+    const valueChanges$ = this.watchStorageChangeByKey(key).pipe(
       map(() => this.obtainFromStorageByKey<T>(key)),
-      startWith(this.obtainFromStorageByKey<T>(key)),
+    );
+    return merge(
+      initialValue$,
+      valueChanges$,
+    ).pipe(
       shareReplay({ refCount: true, bufferSize: 1 }),
     );
   }