1 files changed, 10 insertions, 0 deletions

diff --git a/src/sync/relay_connection.rs b/src/sync/relay_connection.rs
index 6499c27..b0765e8 100644
--- a/src/sync/relay_connection.rs
+++ b/src/sync/relay_connection.rs
@@ -213,4 +213,14 @@ impl RelayConnection {
         self.client.disconnect().await;
         tracing::debug!(relay = %self.url, "Disconnected from relay");
     }
+
+    /// Unsubscribe from all active subscriptions
+    ///
+    /// Used during consolidation to reset all subscriptions before rebuilding
+    /// with consolidated filters. This sends CLOSE messages for all active
+    /// subscriptions on the relay.
+    pub async fn unsubscribe_all(&self) {
+        self.client.unsubscribe_all().await;
+        tracing::debug!(relay = %self.url, "Unsubscribed from all subscriptions");
+    }
 }
\ No newline at end of file