Struct cyfs_lib::WebSocketSession

pub struct WebSocketSession { /* private fields */ }

Implementations

impl WebSocketSession

pub fn new( sid: u32, source: String, conn_info: (SocketAddr, SocketAddr), handler: Box<dyn WebSocketRequestHandler> ) -> Self

pub fn is_valid(&self) -> bool

pub fn requestor(&self) -> &Arc<WebSocketRequestManager>

pub fn sid(&self) -> u32

pub fn conn_info(&self) -> &(SocketAddr, SocketAddr)

pub fn stop(&self)

pub async fn post_msg(&self, msg: Vec<u8>) -> BuckyResult<()>

pub async fn run_client<S>( session: Arc<Self>, service_url: &Url, stream: S ) -> BuckyResult<()>where S: Read + Write + Unpin + Send + 'static,

pub async fn run_server<S>(session: Arc<Self>, stream: S) -> BuckyResult<()>where S: Read + Write + Unpin + Send + 'static,

Trait Implementations

impl Drop for WebSocketSession

fn drop(&mut self)

Executes the destructor for this type.