Struct SubscriptionHandler 

pub struct SubscriptionHandler<'a, S: Db> { /* private fields */ }

Implementations

impl<'a, S: Db> SubscriptionHandler<'a, S>

pub fn new(db: &'a S) -> Self

pub fn init( &self, txn: &mut <S as Db>::RwTx<'_>, introduction: Introduction, ) -> Result<()>

Loads the subscriptions from a software agent introduction

pub fn subscribe(&self, subscriber: AgentId, topic: Topic) -> Result<()>

Subscribes an [‘AgentId’] to a topic from a specific publisher

The changes are automatically commited to DB

pub fn unsubscribe(&self, subscriber: AgentId, topic: Topic) -> Result<()>

Unsubscribes an [‘AgentId’] from a topic

The changes are automatically commited to DB

pub fn get_topic_subscribers( &self, publisher: Id, topic: String, ) -> Result<Vec<(AgentId, String)>>

Fetches the active subscribers for a full topic (publisher + topic)

pub fn get_subscriptions(&self, target: AgentId) -> Result<Vec<Topic>>

Fetches all active subscriptions for the specified [‘AgentId’]

pub fn unsubscribe_all( &self, txn: &mut <S as Db>::RwTx<'_>, subscriber: Id, ) -> Result<()>