Struct ArcRwLockStream

pub struct ArcRwLockStream(/* private fields */);

Implementations

impl ArcRwLockStream

pub fn from(arc_rw_lock_stream: ArcRwLock<TcpStream>) -> Self

pub fn from_stream(stream: TcpStream) -> Self

pub async fn get_read_lock(&self) -> RwLockReadGuardTcpStream<'_>

pub async fn get_write_lock(&self) -> RwLockWriteGuardTcpStream<'_>

pub async fn send(&self, data: &ResponseData) -> ResponseResult

Sends the HTTP response over a TCP stream.

Parameters

• data: Response data

Returns

• Ok: If the response is successfully sent.
• Err: If an error occurs during sending.

pub async fn send_body( &self, body: &ResponseBody, is_websocket: bool, ) -> ResponseResult

Sends the HTTP response body over a TCP stream.

Parameters

• body: Response body.
• is_websocket: Is websocket

Returns

• Ok: If the response body is successfully sent.
• Err: If an error occurs during sending.

pub async fn flush(&self) -> ResponseResult

Flush the TCP stream.

• Returns: A ResponseResult indicating success or failure.

pub async fn close(&self) -> ResponseResult

Closes the stream after sending the response.

This function is responsible for:

• Building the response using the build() method.
• Setting the response using the set_response() method.
• Shutting down the write half of the TCP stream to indicate no more data will be sent.

Returns

• ResponseResult: The result of the operation, indicating whether the closure was successful or if an error occurred.

Trait Implementations

impl Clone for ArcRwLockStream

fn clone(&self) -> ArcRwLockStream

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ArcRwLockStream

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.