fix(connectObservable): fix updates on more than one component

Author: voliva

src/internal/react-enhancer.ts

@@ -11,9 +11,9 @@ const reactEnhancer = <T>(
   delayTime: number,
 ): BehaviorObservable<T> => {
   let finalizeLastUnsubscription = noop
-  let latestValue = EMPTY_VALUE
   const result = new Observable<T>(subscriber => {
     let isActive = true
+    let latestValue = EMPTY_VALUE
     const subscription = source$.subscribe({
       next(value) {
         if (
@@ -97,7 +97,6 @@ const reactEnhancer = <T>(
       }
 
       if (value !== EMPTY_VALUE) {
-        latestValue = value
         return (valueResult = { type: "v", payload: value })
       }
 

src/internal/useObservable.ts

@@ -8,13 +8,16 @@ const SUSP: "s" = "s"
 type Action = "e" | "v" | "s"
 
 const reducer = (
-  _: { type: Action; payload: any },
+  current: { type: Action; payload: any },
   action: { type: Action; payload: any },
 ) => {
   if (action.type === ERROR) {
     throw action.payload
   }
-  return action
+  return Object.is(current.payload, action.payload) &&
+    current.type === action.type
+    ? current
+    : action
 }
 
 const init = (source$: BehaviorObservable<any>) => source$.getValue()