v0.1.3

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@josepot/react-rxjs",
-  "version": "0.1.2",
+  "version": "0.1.3",
   "lockfileVersion": 1,
   "requires": true,
   "dependencies": {

package.json

@@ -1,5 +1,5 @@
 {
-  "version": "0.1.2",
+  "version": "0.1.3",
   "repository": {
     "type": "git",
     "url": "git+https://github.com/josepot/react-rxjs.git"

src/connectFactoryObservable.ts

@@ -1,6 +1,6 @@
 import { useEffect, useState } from "react"
 import { Observable, of } from "rxjs"
-import { finalize, delay, takeUntil } from "rxjs/operators"
+import { delay, takeUntil } from "rxjs/operators"
 import {
   StaticObservableOptions,
   defaultStaticOptions,
@@ -43,10 +43,9 @@ export function connectFactoryObservable<
     }
 
     const reactObservable$ = getObservable(...input).pipe(
-      finalize(() => {
+      distinctShareReplay(compare, () => {
         cache.delete(key)
       }),
-      distinctShareReplay(compare),
     )
 
     cache.set(key, reactObservable$)

src/operators/distinct-share-replay.ts

@@ -1,12 +1,19 @@
 import { Observable, ReplaySubject, concat, NEVER } from "rxjs"
-import { distinctUntilChanged, multicast, refCount } from "rxjs/operators"
+import {
+  distinctUntilChanged,
+  multicast,
+  refCount,
+  finalize,
+} from "rxjs/operators"
 
-const distinctShareReplay = <T>(compare?: (a: T, b: T) => boolean) => (
-  source$: Observable<T>,
-): Observable<T> =>
+const distinctShareReplay = <T>(
+  compare?: (a: T, b: T) => boolean,
+  tearDown?: () => void,
+) => (source$: Observable<T>): Observable<T> =>
   source$.pipe(
     distinctUntilChanged(compare),
     innerSource => concat(innerSource, NEVER),
+    tearDown ? finalize(tearDown) : x => x,
     multicast(() => new ReplaySubject<T>(1)),
     refCount(),
   )