From 735577688d39f6970dca612426b5831688e182eb Mon Sep 17 00:00:00 2001 From: Michael Berger Date: Thu, 25 Jul 2024 09:04:26 +0200 Subject: [PATCH] #111 fix(rx-stateful): fix that initially refresh trigger and sharedSource$ emit multiple values --- libs/rx-stateful/src/lib/rx-stateful$.ts | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/libs/rx-stateful/src/lib/rx-stateful$.ts b/libs/rx-stateful/src/lib/rx-stateful$.ts index 285c091..490e5d2 100644 --- a/libs/rx-stateful/src/lib/rx-stateful$.ts +++ b/libs/rx-stateful/src/lib/rx-stateful$.ts @@ -323,12 +323,19 @@ function createState$( */ // @ts-ignore todo refreshTriggerIsBehaivorSubject(mergedConfig) ? skip(1) : pipe(), + // @ts-ignore switchMap(() => sharedSource$.pipe( map(v => mapToValue(v)), deriveInitialValue(mergedConfig) ), ), + share({ + connector: () => new ReplaySubject(1), + resetOnError: true, + resetOnComplete: true, + resetOnRefCountZero: true, + }), ) as Observable>>