#111 fix(rx-stateful): fix that initially refresh trigger and sharedS…

…ource$ emit multiple values
michaelbe812 · Jul 25, 2024 · 7355776 · 7355776
1 parent bb5bb6f
commit 7355776
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/libs/rx-stateful/src/lib/rx-stateful$.ts b/libs/rx-stateful/src/lib/rx-stateful$.ts
@@ -323,12 +323,19 @@ function createState$<T,A, E>(
              */
             // @ts-ignore todo
             refreshTriggerIsBehaivorSubject(mergedConfig) ? skip(1) : pipe(),
+            // @ts-ignore
             switchMap(() =>
                 sharedSource$.pipe(
                     map(v => mapToValue(v)),
                     deriveInitialValue<T,E>(mergedConfig)
                 ),
             ),
+        share({
+          connector: () => new ReplaySubject(1),
+          resetOnError: true,
+          resetOnComplete: true,
+          resetOnRefCountZero: true,
+        }),
         ) as Observable<Partial<InternalRxState<T, E>>>