fix: userRequests$ multicasted with shareReply (#16)

nichitaa · Feb 8, 2024 · 52adc53 · 52adc53
1 parent 05576f9
commit 52adc53
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 1 deletion.
diff --git a/.changeset/clever-panthers-join.md b/.changeset/clever-panthers-join.md
@@ -0,0 +1,5 @@
+---
+"@nichitaa/rxjs-ws": patch
+---
+
+user request multicast operator
diff --git a/src/core/web-socket-connector.ts b/src/core/web-socket-connector.ts
@@ -188,7 +188,11 @@ export class WebSocketConnector {
       response: defaultResponse,
     };
     const $ = new BehaviorSubject<StreamResponse<TRes, TReqOut, TErr>>(uninitializedValue);
-    const userRequests$ = requests$.pipe(filterNullAndUndefined(), transformRequests);
+    const userRequests$ = requests$.pipe(
+      filterNullAndUndefined(),
+      transformRequests,
+      shareReplay(1),
+    );
 
     userRequests$
       .pipe(