Struct WebSocketSessionManager

pub struct WebSocketSessionManager(/* private fields */);

Implementations

impl WebSocketSessionManager

pub fn new(handler: Box<dyn WebSocketRequestHandler>) -> Self

pub fn get_session(&self, sid: &u32) -> Option<Arc<WebSocketSession>>

pub fn select_session(&self) -> Option<Arc<WebSocketSession>>

pub fn stop(&self)

pub fn new_session( &self, service_url: &Url, conn_info: (SocketAddr, SocketAddr), ) -> BuckyResult<Arc<WebSocketSession>>

pub async fn run_client_session<S>( &self, service_url: &Url, session: Arc<WebSocketSession>, stream: S, ) -> BuckyResult<()>

where S: Read + Write + Unpin + Send + 'static,

pub fn run_server_session<S>( &self, source: String, conn_info: (SocketAddr, SocketAddr), stream: S, )

where S: Read + Write + Unpin + Send + 'static,

Trait Implementations

impl Clone for WebSocketSessionManager

fn clone(&self) -> WebSocketSessionManager

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.