Struct ArcRwLockStream 

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

Thread-safe TCP stream wrapper.

Provides shared access to a TcpStream using Arc and RwLock.

Fields

• Arc<RwLock<TcpStream>> - The protected TCP stream.

Implementations

impl ArcRwLockStream

pub fn from(arc_rw_lock_stream: Arc<RwLock<TcpStream>>) -> ArcRwLockStream

Creates a new ArcRwLockStream from an Arc<RwLock>.

Arguments

• Arc<RwLock<TcpStream>> - The stream to wrap.

Returns

• ArcRwLockStream - The new stream wrapper.

pub fn from_stream(stream: TcpStream) -> ArcRwLockStream

Creates a new ArcRwLockStream from a TcpStream.

Wraps the stream in an Arc<RwLock<_>>.

Arguments

• TcpStream - The raw stream to wrap.

Returns

• ArcRwLockStream - The new thread-safe stream wrapper.

pub async fn read(&self) -> RwLockReadGuard<'_, TcpStream>

Gets a read lock on the inner TcpStream.

Allows shared read access to the stream.

Returns

• RwLockReadGuardTcpStream - The read guard for the stream.

pub async fn send(&self, data: &Vec<u8>) -> Result<(), ResponseError>

Sends HTTP response data over the stream.

Arguments

• &ResponseData - The response data to send.

Returns

• ResponseResult - Result indicating success or failure.

pub async fn send_body_conditional( &self, body: &Vec<u8>, is_websocket: bool, ) -> Result<(), ResponseError>

Sends response body with WebSocket framing condition.

Handles both HTTP and WebSocket response formats.

Arguments

• &ResponseBody - The response body data.
• bool - Whether to use WebSocket framing.

Returns

• ResponseResult - Result indicating success or failure.

pub async fn send_body(&self, body: &Vec<u8>) -> Result<(), ResponseError>

Sends HTTP response body (non-WebSocket).

Convenience wrapper for send_body_conditional with WebSocket disabled.

Arguments

• &ResponseBody - The response body data.

Returns

• ResponseResult - Result indicating success or failure.

pub async fn send_ws_body(&self, body: &Vec<u8>) -> Result<(), ResponseError>

Sends WebSocket response body.

Convenience wrapper for send_body_conditional with WebSocket enabled.

Arguments

• &ResponseBody - The WebSocket frame data.

Returns

• ResponseResult - Result indicating success or failure.

pub async fn flush(&self) -> &ArcRwLockStream

Flushes all buffered data to the stream.

Returns

• &Self - Reference to self for method chaining.

Trait Implementations

impl Clone for ArcRwLockStream

fn clone(&self) -> ArcRwLockStream

Returns a duplicate 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<(), Error>

Formats the value using the given formatter.