Struct WebSocketServer

pub struct WebSocketServer<T>
where
    T: WebSocketHandler + Send + Sync + 'static + Sized,
{
    pub counters: Arc<WebSocketCounters>,
    pub handler: Arc<T>,
    pub stop: DuplexChannel,
}

WebSocketServer that provides the main websocket connection and message processing loop that delivers messages to the installed WebSocketHandler trait.

Fields

counters: Arc<WebSocketCounters>

handler: Arc<T>

stop: DuplexChannel

Implementations

impl<T> WebSocketServer<T>

where T: WebSocketHandler + Send + Sync + 'static,

pub fn new( handler: Arc<T>, counters: Option<Arc<WebSocketCounters>>, ) -> Arc<Self>

pub async fn bind(self: &Arc<Self>, addr: &str) -> Result<TcpListener>

pub async fn listen( self: &Arc<Self>, listener: TcpListener, config: Option<WebSocketConfig>, ) -> Result<()>

pub fn stop(&self) -> Result<()>

pub async fn join(&self) -> Result<()>

pub async fn stop_and_join(&self) -> Result<()>

Trait Implementations

impl<T> WebSocketServerTrait for WebSocketServer<T>

where T: WebSocketHandler + Send + Sync + 'static + Sized,

fn bind<'life0, 'async_trait>( self: Arc<Self>, addr: &'life0 str, ) -> Pin<Box<dyn Future<Output = Result<TcpListener>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn listen<'async_trait>( self: Arc<Self>, listener: TcpListener, config: Option<WebSocketConfig>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait,

fn stop(&self) -> Result<()>

fn join<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn stop_and_join<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,