Struct WsIoServerConnection 

pub struct WsIoServerConnection { /* private fields */ }

Implementations

impl WsIoServerConnection

pub async fn disconnect(&self)

pub async fn emit<D: Serialize>( &self, event: impl AsRef<str>, data: Option<&D>, ) -> Result<()>

pub fn except( self: &Arc<Self>, room_names: impl IntoIterator<Item = impl Into<String>>, ) -> WsIoServerNamespaceBroadcastOperator

pub fn headers(&self) -> &HeaderMap

pub fn id(&self) -> u64

pub fn is_ready(&self) -> bool

pub fn join( self: &Arc<Self>, room_names: impl IntoIterator<Item = impl Into<String>>, )

pub fn leave( self: &Arc<Self>, room_names: impl IntoIterator<Item = impl Into<String>>, )

pub fn namespace(&self) -> Arc<WsIoServerNamespace>

pub fn off(&self, event: impl AsRef<str>)

pub fn off_by_handler_id(&self, event: impl AsRef<str>, handler_id: u32)

pub fn on<H, Fut, D>(&self, event: impl AsRef<str>, handler: H) -> u32

where H: Fn(Arc<WsIoServerConnection>, Arc<D>) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<()>> + Send + 'static, D: DeserializeOwned + Send + Sync + 'static,

pub async fn on_close<H, Fut>(&self, handler: H)

where H: Fn(Arc<WsIoServerConnection>) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

pub fn request_uri(&self) -> &Uri

pub fn server(&self) -> WsIoServer

pub fn to( self: &Arc<Self>, room_names: impl IntoIterator<Item = impl Into<String>>, ) -> WsIoServerNamespaceBroadcastOperator

Trait Implementations

impl TaskSpawner for WsIoServerConnection

fn cancel_token(&self) -> Arc<CancellationToken>

fn spawn_task<F>(&self, future: F)

where F: Future<Output = Result<(), Error>> + Send + 'static,