Struct SessionManager 

pub struct SessionManager { /* private fields */ }

Manages session establishment with deduplication.

When multiple concurrent operations need sessions for overlapping JIDs, this manager ensures only one prekey fetch is performed per JID. Subsequent requests wait for the in-flight fetch to complete.

Implementations

impl SessionManager

pub fn new() -> SessionManager

Create a new SessionManager

pub async fn ensure_sessions<F, H, Fut>( &self, jids: Vec<Jid>, has_session: H, fetch_and_establish: F, ) -> Result<(), SessionError>

where H: Fn(&Jid) -> bool, F: Fn(Vec<Jid>) -> Fut, Fut: Future<Output = Result<(), Error>>,

Ensure sessions exist for the given JIDs.

This method deduplicates requests: if a JID is already being processed, this call will wait for that processing to complete rather than initiating a duplicate fetch.

Arguments

• jids - JIDs that need sessions
• has_session - Closure to check if a session already exists
• fetch_and_establish - Closure to fetch prekeys and establish sessions

Returns

Ok(()) if all sessions were established (or already existed)

pub async fn is_processing(&self, jid: &str) -> bool

Check if a JID is currently being processed

pub async fn processing_count(&self) -> usize

Get the number of JIDs currently being processed

pub async fn pending_count(&self) -> usize

Get the number of JIDs with pending waiters

Trait Implementations

impl Default for SessionManager

fn default() -> SessionManager

Returns the “default value” for a type.