fix: make sure to not crash obserable on case of error

Author: mbret

src/lib/binding/useSubscribe.ts

@@ -2,6 +2,7 @@ import { type DependencyList, useEffect } from "react"
 import { useLiveRef } from "../utils/useLiveRef"
 import { makeObservable } from "../queries/client/utils/makeObservable"
 import { type SubscribeSource } from "./types"
+import { catchError, EMPTY } from "rxjs"
 
 export function useSubscribe<T>(
   source: SubscribeSource<T>,
@@ -10,7 +11,15 @@ export function useSubscribe<T>(
   const sourceRef = useLiveRef(source)
 
   useEffect(() => {
-    const sub = makeObservable(sourceRef.current).subscribe()
+    const sub = makeObservable(sourceRef.current)
+      .pipe(
+        catchError((error) => {
+          console.error(error)
+
+          return EMPTY
+        })
+      )
+      .subscribe()
 
     return () => {
       sub.unsubscribe()