Pairing request subscription fixed

WalletConnect · Oct 19, 2022 · 15dd4b2 · 15dd4b2
1 parent 3fb5c2a
commit 15dd4b2
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/Sources/WalletConnectPairing/PairingRequestsSubscriber.swift b/Sources/WalletConnectPairing/PairingRequestsSubscriber.swift
@@ -22,8 +22,17 @@ public class PairingRequestsSubscriber {
     }
 
     func subscribeForRequest<RequestParams: Codable>(_ protocolMethod: ProtocolMethod) -> AnyPublisher<RequestSubscriptionPayload<RequestParams>, Never> {
+
         registeredProtocolMethods.insert(protocolMethod.method)
-        return networkingInteractor.requestSubscription(on: protocolMethod).eraseToAnyPublisher()
+
+        let publisherSubject = PassthroughSubject<RequestSubscriptionPayload<RequestParams>, Never>()
+
+        networkingInteractor.requestSubscription(on: protocolMethod)
+            .sink { (payload: RequestSubscriptionPayload<RequestParams>) in
+                publisherSubject.send(payload)
+            }.store(in: &publishers)
+
+        return publisherSubject.eraseToAnyPublisher()
     }
 
     func handleUnregisteredRequests() {