From 52adc535a41c493a67802870b44e1277355721be Mon Sep 17 00:00:00 2001
From: Pasecinic Nichita <nichita.pasecinic@jivygroup.com>
Date: Thu, 8 Feb 2024 21:27:45 +0200
Subject: [PATCH] fix: `userRequests$` multicasted with shareReply (#16)

---
 .changeset/clever-panthers-join.md | 5 +++++
 src/core/web-socket-connector.ts   | 6 +++++-
 2 files changed, 10 insertions(+), 1 deletion(-)
 create mode 100644 .changeset/clever-panthers-join.md

diff --git a/.changeset/clever-panthers-join.md b/.changeset/clever-panthers-join.md
new file mode 100644
index 0000000..8cabbce
--- /dev/null
+++ 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
index 2a289fd..f9772b0 100644
--- 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(