Struct QuerySubscriptionManager 

pub struct QuerySubscriptionManager { /* private fields */ }

Manages registered query names and active per-key watchers.

Implementations

impl QuerySubscriptionManager

pub fn new( registered: Vec<RegisteredQuery>, ttls: HashMap<String, Duration>, ) -> Self

Creates a new manager from the registered queries and optional per-query TTLs.

pub fn get_query(&self, name: &str) -> Option<&str>

Returns the GraphQL query string for a given name, if registered.

pub fn subscribe<C: ClientContext + 'static>( self: &Arc<Self>, key: &SubscriptionKey, context: Arc<Mutex<C>>, token: CancellationToken, ) -> Result<Receiver<Option<String>>>

Returns a watch receiver for the given key. Lazily spawns a watcher if needed. The receiver initially holds None; the watcher populates it with Some(value) after the first query. Callers should filter out None values from the stream.