From 15dd4b28c1d335754cfa96462b1bfe1da0f897c0 Mon Sep 17 00:00:00 2001 From: Artur Guseinov Date: Wed, 19 Oct 2022 17:16:25 +0600 Subject: [PATCH] Pairing request subscription fixed --- .../PairingRequestsSubscriber.swift | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/Sources/WalletConnectPairing/PairingRequestsSubscriber.swift b/Sources/WalletConnectPairing/PairingRequestsSubscriber.swift index f108087920..994f53773f 100644 --- a/Sources/WalletConnectPairing/PairingRequestsSubscriber.swift +++ b/Sources/WalletConnectPairing/PairingRequestsSubscriber.swift @@ -22,8 +22,17 @@ public class PairingRequestsSubscriber { } func subscribeForRequest(_ protocolMethod: ProtocolMethod) -> AnyPublisher, Never> { + registeredProtocolMethods.insert(protocolMethod.method) - return networkingInteractor.requestSubscription(on: protocolMethod).eraseToAnyPublisher() + + let publisherSubject = PassthroughSubject, Never>() + + networkingInteractor.requestSubscription(on: protocolMethod) + .sink { (payload: RequestSubscriptionPayload) in + publisherSubject.send(payload) + }.store(in: &publishers) + + return publisherSubject.eraseToAnyPublisher() } func handleUnregisteredRequests() {