feat: defer to avoid sharing subject between subscribers

index.ts

@@ -1,4 +1,5 @@
 import {
+  defer,
   from,
   Observable,
   ObservableInput,
@@ -18,23 +19,23 @@ import {exhaustMap, finalize, throttle} from "rxjs/operators"
 export function exhaustMapWithTrailing<T, R>(
   project: (value: T, index: number) => ObservableInput<R>
 ): OperatorFunction<T, R> {
-  return (source): Observable<R> => {
-    const release = new Subject<void>()
-
-    return source.pipe(
-      throttle(() => release, {
-        leading: true,
-        trailing: true,
-      }),
-      exhaustMap((value, index) =>
-        from(project(value, index)).pipe(
-          finalize(() => {
-            release.next()
-          })
+  return (source): Observable<R> =>
+    defer(() => {
+      const release = new Subject<void>()
+      return source.pipe(
+        throttle(() => release, {
+          leading: true,
+          trailing: true,
+        }),
+        exhaustMap((value, index) =>
+          from(project(value, index)).pipe(
+            finalize(() => {
+              release.next()
+            })
+          )
         )
       )
-    )
-  }
+    })
 }
 
 /**