diff --git a/Sources/Web3Inbox/NotifyClientProxy/NotifyClientRequest.swift b/Sources/Web3Inbox/NotifyClientProxy/NotifyClientRequest.swift index b152330ce..ddac26a48 100644 --- a/Sources/Web3Inbox/NotifyClientProxy/NotifyClientRequest.swift +++ b/Sources/Web3Inbox/NotifyClientProxy/NotifyClientRequest.swift @@ -5,6 +5,7 @@ enum NotifyClientRequest: String { case notifyUpdate = "notify_update" case notifyDelete = "notify_delete" case notifySubscription = "notify_subscription" + case notifySubscriptionsChanged = "notify_subscriptions_changed" var method: String { return rawValue diff --git a/Sources/Web3Inbox/NotifyClientProxy/NotifyClientRequestSubscriber.swift b/Sources/Web3Inbox/NotifyClientProxy/NotifyClientRequestSubscriber.swift index 8b255bd81..a9c4c1558 100644 --- a/Sources/Web3Inbox/NotifyClientProxy/NotifyClientRequestSubscriber.swift +++ b/Sources/Web3Inbox/NotifyClientProxy/NotifyClientRequestSubscriber.swift @@ -33,6 +33,9 @@ final class NotifyClientRequestSubscriber { client.updateSubscriptionPublisher.sink { [unowned self] subscription in handle(event: .notifyUpdate, params: subscription) }.store(in: &publishers) + client.subscriptionsPublisher.sink { [unowned self] subscriptions in + handle(event: .notifySubscriptionsChanged, params: subscriptions) + }.store(in: &publishers) } }