Struct WebSocketReader 

pub struct WebSocketReader { /* private fields */ }

Runner thread for a websockets connection

Implementations

impl WebSocketReader

pub fn new_unchecked(read_stream: OwnedReadHalf) -> WebSocketReader

Generates a new instance of the websocket reader, assuming the handshake has already been performed

pub fn set_permit(&mut self, permit: OwnedSemaphorePermit)

Auxiliar function that cataclysm uses to keep track of connections

pub async fn try_read_frame(&self) -> Result<Frame, Error>

Blocks until a message is received

pub fn spawn<H: WebSocketThread + 'static>( self, wst: H, ) -> JoinHandle<<H as WebSocketThread>::Output>

Spawns a tokio thread that dispatches the message to the proved handler

Trait Implementations

impl AsRef<TcpStream> for WebSocketReader

fn as_ref(&self) -> &TcpStream

Converts this type into a shared reference of the (usually inferred) input type.

impl From<WebSocketReader> for OwnedReadHalf

fn from(source: WebSocketReader) -> OwnedReadHalf

Converts to this type from the input type.