Struct workflow_websocket::server::WebSocketServer

pub struct WebSocketServer<T>where
    T: WebSocketHandler + Send + Sync + 'static + Sized,{
    pub connections: AtomicU64,
    pub handler: Arc<T>,
}

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

Fields

connections: AtomicU64

handler: Arc<T>

Implementations

impl<T> WebSocketServer<T>where
    T: WebSocketHandler + Send + Sync + 'static,

pub fn new(handler: Arc<T>) -> Arc<Self>

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