keep memory of last value seen

psiori · Jul 21, 2021 · abf6ff0 · abf6ff0
1 parent c9dcb86
commit abf6ff0
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/projects/akita-ng-fire/src/lib/utils/share-delay.ts b/projects/akita-ng-fire/src/lib/utils/share-delay.ts
@@ -19,16 +19,19 @@ export function shareWithDelay<T>(delay: number = 100): MonoTypeOperatorFunction
   let refCount = 0;
   let hasError = false;
   let isComplete = false;
+  let lastValue: T;
   function operation(this: Subscriber<T>, source: Observable<T>) {
     refCount++;
     let innerSub: Subscription | undefined;
     if (!subject || hasError) {
       hasError = false;
       subject = new ReplaySubject<T>(1, Infinity);
+      if (lastValue) subject.next(lastValue);
       innerSub = subject.subscribe(this);
       subscription = source.subscribe({
         next(value) {
           subject?.next(value);
+          lastValue = value;
         },
         error(err) {
           hasError = true;