Struct SubscriptionManager 

pub struct SubscriptionManager { /* private fields */ }

Manages resource subscriptions for the connected MCP client.

Thread-safe: uses an internal Mutex so it can be shared across async tasks without requiring &mut self.

Implementations

impl SubscriptionManager

pub fn new() -> Self

Create a new empty subscription manager.

pub fn subscribe(&self, uri: &str) -> bool

Subscribe to a resource URI. Returns true if newly added.

pub fn unsubscribe(&self, uri: &str) -> bool

Unsubscribe from a resource URI. Returns true if was present.

pub fn has_subscriptions(&self) -> bool

Check if any subscriptions are registered.

pub fn affected_subscriptions(&self, mutations: &[MutationKind]) -> Vec<String>

Given a set of mutation kinds, return the subscribed URIs that need notification. Only returns URIs that the client has actually subscribed to.

Trait Implementations

impl Default for SubscriptionManager

fn default() -> Self

Returns the “default value” for a type.