Struct ClientSession 

pub struct ClientSession { /* private fields */ }

Client session wrapping a TCP connection.

Implementations

impl ClientSession

pub fn new(stream: TcpStream) -> Self

Creates a new client session from a TCP stream.

pub fn with_max_frame_size(stream: TcpStream, max_frame_size: usize) -> Self

Creates a new client session with custom frame size.

pub async fn send(&mut self, message: &[u8]) -> Result<()>

Sends a message to the server.

Errors

Returns IO error if send fails.

pub async fn recv(&mut self) -> Result<Option<BytesMut>>

Receives a message from the server.

Returns

Ok(Some(bytes)) if received, Ok(None) if connection closed.

Errors

Returns IO error if receive fails.

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

Closes the session.