Struct ConnectionSession 

pub struct ConnectionSession { /* private fields */ }

Connection session pool for managing multiple websocket sessions

Implementations

impl ConnectionSession

pub fn new<F, D>( max_async: usize, connect_fn: F, dispatch_fn: D, api: BotApi, ) -> Self

where F: Fn(Session) -> Pin<Box<dyn Future<Output = Result<(), BotError>> + Send>> + Send + Sync + 'static, D: Fn(&str, Value) + Send + Sync + 'static,

Create a new connection session

pub fn add_session(&mut self, session: Session)

Add a session to the connection pool

pub async fn multi_run(self, session_interval: u64) -> Result<(), BotError>

Run multiple sessions with specified interval

pub fn state(&self) -> Arc<Mutex<ConnectionState>>

Get the connection state