Struct WebSocketServer 

pub struct WebSocketServer<M> { /* private fields */ }

Implementations

impl<M> Server<M>

where M: Clone,

pub fn new(cfg: &Config) -> Self

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

pub fn with_message_handler<F, Fut>(self, h: F) -> Self

where F: Fn(M) -> Fut + Send + Sync + 'static, Fut: Future<Output = Option<M>> + Send + Sync + 'static,

pub fn with_error_handler<F, Fut>(self, h: F) -> Self

where F: Fn(Box<dyn Error + Send + Sync + 'static>) -> Fut + Send + Sync + 'static, Fut: Future<Output = ()> + Send + Sync + 'static,

pub async fn broadcast(&self, msg: M) -> Result<usize, SendError<M>>

pub async fn handle_stream<S, E>(&self, s: S)

where M: Debug + Send + Sync + 'static, S: StreamExt<Item = Result<M, E>> + SinkExt<M, Error = E> + Sized + Send + 'static, E: Error + Send + Sync + 'static,

impl Server<Message>

pub async fn run(&self)

Trait Implementations

impl<M: Clone> Clone for Server<M>

fn clone(&self) -> Server<M>

Returns a duplicate of the value.

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

Performs copy-assignment from source.