Struct WebSocketGatewayConnection 

pub struct WebSocketGatewayConnection { /* private fields */ }

In-process WebSocket gateway connection used by adapters and tests.

Implementations

impl WebSocketGatewayConnection

pub fn id(&self) -> u64

pub fn request(&self) -> &BootRequest

pub fn namespace(&self) -> Option<&str>

pub fn server(&self) -> WebSocketGatewayServer

pub fn rooms(&self) -> Result<Vec<String>>

pub fn join(&self, room: impl Into<String>) -> Result<()>

pub fn leave(&self, room: impl Into<String>) -> Result<()>

pub async fn emit(&self, message: WebSocketMessage) -> Result<bool>

pub async fn broadcast(&self, message: WebSocketMessage) -> Result<usize>

pub async fn broadcast_to_room( &self, room: impl Into<String>, message: WebSocketMessage, ) -> Result<usize>

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

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

pub async fn dispatch( &self, message: WebSocketMessage, ) -> Result<Option<WebSocketMessage>>

Trait Implementations

impl Clone for WebSocketGatewayConnection

fn clone(&self) -> WebSocketGatewayConnection

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl WebSocketConnection for WebSocketGatewayConnection

fn request(&self) -> &BootRequest

fn dispatch( &self, message: WebSocketMessage, ) -> BoxFuture<'static, Result<Option<WebSocketMessage>>>