INNER CODE UNIT · Rust
cleanup_subscriptions
aannoo/hcom · src/db/mod.rs:953
pub fn cleanup_subscriptions(&self, name: &str) -> Result<u32> {
// Delegates to db::subscriptions; events_sub: kv ownership lives there.
subscriptions::cleanup_subscriptions(self, name)
}
/// Remove delivery-only thread memberships for an instance.
///
/// This is used when a stopped name is being reused by a fresh instance:
/// normal stop/resume should preserve memberships, but identity replacement
/// must not inherit old thread state.
pub fn cleanup_thread_memberships_for_name_reuse(&self, name: &str) -> Result<u32> {
// Delegates to db::subscriptions; events_sub: kv ownership lives there.
subscriptions::cleanup_thread_memberships_for_name_reuse(self, name)
}
/// Return active members of a thread in join order.
pub fn get_thread_members(&self, thread: &str) -> Vec<String> {
// Delegates to db::subscriptions; events_sub: kv ownership lives there.