Struct workflow_rpc::server::WebSocketServer

pub struct WebSocketServer<T>where
    T: WebSocketHandler + Send + Sync + 'static,{
    pub connections: AtomicU64,
    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

connections: AtomicU64

handler: Arc<T>

stop: DuplexChannel<(), ()>

Implementations

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

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

pub async fn listen(
self: Arc<WebSocketServer<T>>,
addr: &str
) -> impl Future<Output = Result<(), Error>>

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

pub async fn join(&self) -> impl Future<Output = Result<(), Error>>

pub async fn stop_and_join(&self) -> impl Future<Output = Result<(), Error>>

Trait Implementations

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

fn listen<'life0, 'async_trait>(
self: Arc<WebSocketServer<T>>,
addr: &'life0 str
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>>where
'life0: 'async_trait,
WebSocketServer<T>: 'async_trait,

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

fn join<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>>where
'life0: 'async_trait,
WebSocketServer<T>: 'async_trait,

fn stop_and_join<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>>where
'life0: 'async_trait,
WebSocketServer<T>: 'async_trait,